diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-07-16 09:22:11 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2016-07-16 09:22:11 -0700 |
| commit | a7000baaedc4b2e3502e3d381687a6df9ba7c2d3 (patch) | |
| tree | 8d8b2c02b3c28bda437c6914f165b7782a54adeb /kafka/protocol/commit.py | |
| parent | 7a350e5fcf33f49094c820ba88b9cee4aeae6e12 (diff) | |
| download | kafka-python-a7000baaedc4b2e3502e3d381687a6df9ba7c2d3.tar.gz | |
Fix KafkaConsumer autocommit for 0.8 brokers (#756 / #706)
* Dont wait for group join to enable AutoCommitTask if broker version < 0.9
* For zookeeper offset storage, set a "coordinator" with least_loaded_node
Diffstat (limited to 'kafka/protocol/commit.py')
0 files changed, 0 insertions, 0 deletions