Dana Powers a7000baaed 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

2016-07-16 09:22:11 -07:00

..

assignors

Add RangePartitionAssignor (and use as default); add assignor tests

2016-02-16 12:41:00 -08:00

__init__.py

AbstractCoordinator (modelled after upstream Java class)

2015-12-28 15:18:43 -08:00

base.py

Fix KafkaConsumer autocommit for 0.8 brokers (#756 / #706)

2016-07-16 09:22:11 -07:00

consumer.py

Fix KafkaConsumer autocommit for 0.8 brokers (#756 / #706)

2016-07-16 09:22:11 -07:00

heartbeat.py

Remove unused imports

2016-04-05 10:22:54 -07:00

protocol.py

Update imports from kafka.common -> kafka.errors / kafka.structs

2016-04-05 09:35:45 -07:00