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

Drain pending requests to the coordinator before initiating group rejoin (#798)

2016-08-05T03:09:13+00:00

Change coordinator.needs_join_prepare -> coordinator.rejoining; fix consumer group test (#795)

2016-08-04T22:31:41+00:00

Treat metric_group_prefix as config in KafkaConsumer

2016-08-04T20:05:36+00:00

Always absolute_import

2016-08-03T04:36:00+00:00

Vendor six 1.10.0

2016-08-01T21:47:40+00:00

Add base coordinator metrics

2016-07-18T00:54:06+00:00

KAFKA-3486: fix autocommit when partitions assigned manually (#767 / #626)

2016-07-17T16:29:45+00:00

KAFKA-3117: handle metadata updates during consumer rebalance (#766 / #701)

2016-07-17T15:37:44+00:00

KAFKA-2832: Add a consumer config option to exclude internal topics (#765)

2016-07-17T15:37:15+00:00

  Use exclude_internal_topics config in KafkaConsumer to avoid subscribe patterns matching internal topics
  Raise error during rebalance if subscribed topics are not authorized

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