delta/python-packages/kafka-python.git/kafka/consumer, branch fetch_compacted_offset github.com: mumrah/kafka-python.git Fix PartitionRecords handling of compacted messages 2018-02-26T21:45:58+00:00 Dana Powers dana.powers@rd.io 2018-02-26T21:45:58+00:00 c32a0459781e33c45d1bd1aa85148beebd8a7b09 






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






KAFKA-3888 Use background thread to process consumer heartbeats (#1266)
2017-12-21T22:46:10+00:00

Dana Powers
dana.powers@gmail.com

2017-12-21T22:46:10+00:00

ad024d1e897dbf16bd629fa63895bd7af4a8d959












Minor Exception cleanup
2017-12-12T19:06:44+00:00

Jeff Widman
jeff@jeffwidman.com

2017-12-07T23:07:31+00:00

580520bcb9dc2ed9725e4b4871cd275f6826a182












Revert ffc7caef13a120f69788bcdd43ffa01468f575f9 / PR #1239
2017-11-17T07:17:55+00:00

Dana Powers
dana.powers@gmail.com

2017-11-17T07:16:26+00:00

16e05e7f8b4553343b47462595b9743f1f8ab900

The change caused a regression documented in issue #1290





The change caused a regression documented in issue #1290