Parsely / pykafka

Compare 19d87f8 ... +0 ... 73f8e8e

Showing 1 of 1 files from the diff.

@@ -287,7 +287,8 @@
Loading
287 287
            self.host, self.port, self._handler,
288 288
            buffer_size=self._buffer_size,
289 289
            source_host=self._source_host, source_port=self._source_port,
290 -
            ssl_config=self._ssl_config)
290 +
            ssl_config=self._ssl_config,
291 +
            sasl_authenticator=self._sasl_authenticator)
291 292
        self._offsets_channel_connection.connect(self._offsets_channel_socket_timeout_ms,
292 293
                                                 attempts=attempts)
293 294
        self._offsets_channel_req_handler = RequestHandler(

Learn more Showing 10 files with coverage changes found.

Changes in pykafka/partition.py
-8
+3
+5
Loading file...
Changes in pykafka/broker.py
-2
+2
Loading file...
Changes in pykafka/topic.py
-1
+1
Loading file...
Changes in pykafka/connection.py
-1
+1
Loading file...
Changes in pykafka/handlers.py
-1
+1
Loading file...
Changes in pykafka/simpleconsumer.py
-1
+1
Loading file...
New file pykafka/rdkafka/_rd_kafkamodule.c
New
Loading file...
Changes in pykafka/cluster.py
-4
+3
+1
Loading file...
Changes in pykafka/balancedconsumer.py
-1
-3
+4
Loading file...
Changes in pykafka/utils/socket.py
-1
+1
Loading file...
Files Coverage
pykafka -1.80% 81.98%
Project Totals (37 files) 81.98%
Loading