delta/python-packages/kafka-python.git/kafka, branch kafka_error_str

Args are optional in BrokerResponseError str

2016-11-18T17:06:21+00:00

Revert consumer iterators from max_poll_records (#856)

2016-10-24T18:24:16+00:00

Fix murmur2 bug handling python2 bytes that do not ascii encode (#815)

2016-10-22T16:48:08+00:00

* Add test for murmur2 py2 bytes bug
* Fix murmur2 handling of python2 bytes
* Drop bytearray / str / unicode MurmurPartitioner tests -- no longer supported
* Make DefaultPartitioner importable from kafka.partitioner

Bugfix on max_poll_records - TypeError: object of type NoneType has no len()

2016-10-04T17:10:10+00:00

KAFKA-3007: KafkaConsumer max_poll_records (#831)

2016-09-28T19:39:34+00:00

Update Partitioners for use with KafkaProducer (#827)

2016-09-28T17:30:32+00:00

Monkeypatch max_in_flight_requests_per_connection when checking broker version (#834)

2016-09-28T16:56:11+00:00

Fix message timestamp_type (#828)

2016-09-15T23:29:19+00:00

Added ssl_password config option to KafkaProducer class, identical to… (#830)

2016-09-15T23:28:59+00:00

* Added ssl_password config option to KafkaProducer class, identical to option in KafkaConsumer class

* removed non-ascii characters

* changed - to : in comments

from kafka import ConsumerRebalanceListener, OffsetAndMetadata

2016-09-04T16:26:41+00:00