delta/python-packages/kafka-python.git/kafka, branch drop_pytest_sugar github.com: mumrah/kafka-python.git Fix for Python 3 byte string handling in SASL auth (#1353) 2018-01-24T19:26:22+00:00 Christophe Lecointe christophe.lecointe@tuta.io 2018-01-24T19:26:22+00:00 351f418ba5b62c28c8cff5ea7dcca8e37cadcf8e 






Remove assertion with side effect (#1348)
2018-01-23T17:49:18+00:00

Buğra Gedik
bgedik@gmail.com

2018-01-23T17:49:18+00:00

bfa6e2044ad7ecef8ab042d43e2c4d47467d3949












fix reconnect_backoff_max_ms default config bug in KafkaProducer (#1352)
2018-01-23T17:48:58+00:00

C.YAO
YaoC@users.noreply.github.com

2018-01-23T17:48:58+00:00

8f8201713676db2f6ea3828cc376cbed2665dcd2












Name heartbeat thread with group_id; use backoff when polling (#1345)
2018-01-16T18:52:33+00:00

Dana Powers
dana.powers@gmail.com

2018-01-16T18:52:33+00:00

13490fa2b17a8ad909b11a243aaf38ba491293ee















Avoid KeyError when filtering fetchable partitions (#1344)
2018-01-12T20:48:43+00:00

Dana Powers
dana.powers@gmail.com

2018-01-12T20:48:43+00:00

298709d2590b201dfe1b8753baacd1d2b554710f

* Avoid KeyError when filtering fetchable partitions





* Avoid KeyError when filtering fetchable partitions







Honor reconnect_backoff in conn.connect() (#1342)
2018-01-12T01:38:47+00:00

Dana Powers
dana.powers@gmail.com

2018-01-12T01:38:47+00:00

a8bf19f88e89bef571b7c1f952010bf405054987

* Honor reconnect_backoff in conn.connect()




* Honor reconnect_backoff in conn.connect()






Fix coordinator join_future race condition (#1338)
2018-01-11T22:48:38+00:00

Dana Powers
dana.powers@gmail.com

2018-01-11T22:48:38+00:00

da65a562bdd9ce20290d4375acc36b4977ef7026

* Fix race condition in coordinator join_future handling




* Fix race condition in coordinator join_future handling






Read all available socket bytes (#1332)
2018-01-11T01:25:33+00:00

Dana Powers
dana.powers@gmail.com

2018-01-11T01:25:33+00:00

a69320b8e3199fa9d7cfa3947a242e699a045c3b

* Recv all available network bytes before parsing
* Add experimental support for configuring socket chunking parameters




* Recv all available network bytes before parsing
* Add experimental support for configuring socket chunking parameters






Improve KafkaConsumer cleanup (#1339)
2018-01-10T23:56:47+00:00

Dana Powers
dana.powers@gmail.com

2018-01-10T23:56:47+00:00

0a7492443c78d4791cfdf3d6384c02f1c7757c7b












Fix typo in _try_authenticate_plain (#1333)
2017-12-28T16:59:58+00:00

everpcpc
git@everpcpc.com

2017-12-28T16:59:58+00:00

794b695e7ceff25834616bb54e32160104040df4