delta/python-packages/kafka-python.git/kafka/consumer/fetcher.py, branch jeffwidman-patch-1

1701 use last offset from fetch v4 if available (#1724)

2019-03-13T13:48:53+00:00

Remove unused `skip_double_compressed_messages`

2019-01-13T21:53:18+00:00

This `skip_double_compressed_messages` flag was added in https://github.com/dpkp/kafka-python/pull/755 in
order to fix https://github.com/dpkp/kafka-python/issues/718.

However, grep'ing through the code, it looks like it this is no longer
used anywhere and doesn't do anything.

So removing it.

Be explicit with tuples for %s formatting

2018-11-18T08:21:18+00:00

Fix #1633

Expose record headers in ConsumerRecords

2018-09-27T22:22:03+00:00

Stop using deprecated log.warn()

2018-05-10T23:33:37+00:00

Use local copies in Fetcher._fetchable_partitions to avoid mutation errors (#1400)

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

Fix KafkaConsumer compacted offset handling (#1397)

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

Avoid consuming duplicate compressed messages from mid-batch (#1367)

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

KAFKA-3949: Avoid race condition when subscription changes during rebalance (#1364)

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

Avoid KeyError when filtering fetchable partitions (#1344)

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

* Avoid KeyError when filtering fetchable partitions