delta/python-packages/kafka-python.git/kafka/consumer, branch commit_failed_message_fixup github.com: mumrah/kafka-python.git Avoid tight poll loop in consumer when brokers are down (#1415) 2018-03-08T16:18:15+00:00 Dana Powers dana.powers@gmail.com 2018-03-08T16:18:15+00:00 4abdb1baea2468408c36cc983dfef1e8b8f54654 






Use local copies in Fetcher._fetchable_partitions to avoid mutation errors (#1400)
2018-03-08T01:07:09+00:00

Dana Powers
dana.powers@gmail.com

2018-03-08T01:07:09+00:00

a6130d288f84af7ffe054bdf301bc40febe07719












Validate max_records in KafkaConsumer.poll (#1398)
2018-02-27T17:30:47+00:00

Dana Powers
dana.powers@gmail.com

2018-02-27T17:30:47+00:00

793dc4dd4f1fdce9167a23e08ddb3841ea69805b












Fix KafkaConsumer compacted offset handling (#1397)
2018-02-26T23:03:10+00:00

Dana Powers
dana.powers@gmail.com

2018-02-26T23:03:10+00:00

4cadaafb24c2bdad475a68e3df5a4e19ce043ce7












Correctly respect timeouts in consumer poll interface (#1384)
2018-02-21T18:00:19+00:00

Braedon Vickers
braedon.vickers@gmail.com

2018-02-21T18:00:19+00:00

92635d9bfff5593ba865003dd3010a0feb280140












use absolute imports everywhere (#1362)
2018-02-06T20:10:45+00:00

Kevin Tindall
kevinkjt2000@users.noreply.github.com

2018-02-06T20:10:45+00:00

9ae0e590b5ea93a9c07d71b55b593e0fcc973bc6












Avoid consuming duplicate compressed messages from mid-batch (#1367)
2018-02-06T00:25:18+00:00

Dana Powers
dana.powers@gmail.com

2018-02-06T00:25:18+00:00

441aeb864519d2f574650e24a327423308adca03












KAFKA-3949: Avoid race condition when subscription changes during rebalance (#1364)
2018-02-03T00:36:30+00:00

Dana Powers
dana.powers@gmail.com

2018-02-03T00:36:30+00:00

618c5051493693c1305aa9f08e8a0583d5fcf0e3












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







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