delta/python-packages/kafka-python.git/kafka/coordinator, branch config_selector

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

2016-07-16T16:22:11+00:00

  * Dont wait for group join to enable AutoCommitTask if broker version < 0.9
  * For zookeeper offset storage, set a "coordinator" with least_loaded_node

Avoid some exceptions in Coordinator.del (#668)

2016-04-25T20:12:43+00:00

Changing some commented out metrics to avoid future gotchas.

2016-04-14T00:26:39+00:00

Beginnings of metrics instrumentation in kafka consumer.

2016-04-14T00:26:39+00:00

This adds the parent metrics instance to kafka consumer, which will
eventually be used to instrument everything under consumer. To start
I ported the java consumer coordinator metrics.

Default sleep=True in client.poll

2016-04-08T16:23:57+00:00

Can no longer have coordinator_id if coordinator_unknown()

2016-04-08T16:23:57+00:00

Use version-indexed lists for request/response protocol structs

2016-04-06T05:54:28+00:00

Remove unused imports

2016-04-05T17:22:54+00:00

KAFKA-3318: clean up consumer logging and error messages