delta/python-packages/kafka-python.git/kafka/consumer/group.py, branch commit_failed_message_fixupgithub.com: mumrah/kafka-python.git
Avoid tight poll loop in consumer when brokers are down (#1415)2018-03-08T16:18:15+00:00Dana Powersdana.powers@gmail.com2018-03-08T16:18:15+00:004abdb1baea2468408c36cc983dfef1e8b8f54654
Validate max_records in KafkaConsumer.poll (#1398)2018-02-27T17:30:47+00:00Dana Powersdana.powers@gmail.com2018-02-27T17:30:47+00:00793dc4dd4f1fdce9167a23e08ddb3841ea69805b
Correctly respect timeouts in consumer poll interface (#1384)2018-02-21T18:00:19+00:00Braedon Vickersbraedon.vickers@gmail.com2018-02-21T18:00:19+00:0092635d9bfff5593ba865003dd3010a0feb280140
KAFKA-3949: Avoid race condition when subscription changes during rebalance (#1364)2018-02-03T00:36:30+00:00Dana Powersdana.powers@gmail.com2018-02-03T00:36:30+00:00618c5051493693c1305aa9f08e8a0583d5fcf0e3
Read all available socket bytes (#1332)2018-01-11T01:25:33+00:00Dana Powersdana.powers@gmail.com2018-01-11T01:25:33+00:00a69320b8e3199fa9d7cfa3947a242e699a045c3b
* 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
KAFKA-3888 Use background thread to process consumer heartbeats (#1266)2017-12-21T22:46:10+00:00Dana Powersdana.powers@gmail.com2017-12-21T22:46:10+00:00ad024d1e897dbf16bd629fa63895bd7af4a8d959
Use correct casing for MB2017-11-15T22:40:12+00:00Jeff Widmanjeff@jeffwidman.com2017-11-15T22:38:16+00:007bde919f2732e34cd76c858c79d965db528a0096
These values refer to Megabytes, not Megabits.
Fix #1295
These values refer to Megabytes, not Megabits.
Fix #1295
Fix overriding sasl_kerberos_service_name in KafkaConsumer / KafkaProducer (#1264)2017-10-17T23:03:33+00:00Nathanael Smithnatedogs911@gmail.com2017-10-17T23:03:33+00:0013752d74ef6d4c947146899668fa41c6a317bb3f