delta/python-packages/kafka-python.git/test/test_fetcher.py, branch bump_versions github.com: mumrah/kafka-python.git Optionally return OffsetAndMetadata from consumer.committed(tp) (#1979) 2019-12-30T00:06:24+00:00 Dana Powers dana.powers@gmail.com 2019-12-30T00:06:24+00:00 2a86b23f477e5ed57aa987db97d11284a37d05a0 






Issue #1780 - Consumer hang indefinitely in fetcher._retrieve_offsets() due to topic deletion while rebalancing  (#1782)
2019-09-30T14:23:06+00:00

Commander Dishwasher
roy.antman@gmail.com

2019-09-30T14:23:06+00:00

298cb0dbef58f6bb267235911b6ca86039bf8cda












Do not use wakeup when sending fetch requests from consumer (#1911)
2019-09-29T14:56:12+00:00

Dana Powers
dana.powers@gmail.com

2019-09-29T14:56:12+00:00

9de12d3f03236988a60e6cd79a50ffa5165cf735












Expose record headers in ConsumerRecords
2018-09-27T22:22:03+00:00

Heikki Nousiainen
htn@aiven.io

2018-08-14T12:38:42+00:00

0ca4313170df2657456009af5550942ace9f1a81












Don't use `kafka.common` internally
2018-06-05T21:32:01+00:00

Jeff Widman
jeff@jeffwidman.com

2018-05-28T22:58:26+00:00

bc4cc434cddf403a35d0393d68ecfdbfad17c8e5

This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`.





This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`.







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












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












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







Add DefaultRecordBatch implementation aka V2 message format parser/builder. (#1185)
2017-10-24T22:28:35+00:00

Taras Voinarovskyi
voyn1991@gmail.com

2017-10-24T22:28:35+00:00

8b05ee8da50b4c7b832676f4e38f9d92a86639cc

Added bytecode optimization for varint and append/read_msg functions. Mostly based on avoiding LOAD_GLOBAL calls.




Added bytecode optimization for varint and append/read_msg functions. Mostly based on avoiding LOAD_GLOBAL calls.






Fix tests and rebase problems
2017-10-12T08:10:44+00:00

Taras
voyn1991@gmail.com

2017-10-11T17:02:18+00:00

e992fbfad926486766ff7b63a499f9cf29984fec