delta/python-packages/kafka-python.git/test/test_coordinator.py, branch 1.3.0

Treat metric_group_prefix as config in KafkaConsumer

2016-08-04T20:05:36+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

Add api_version config to KafkaClient, deprecate str in favor of tuples (#761)

2016-07-16T20:04:28+00:00

Include zk-offset configuration in coordinator unit tests

2016-07-16T17:31:01+00:00

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

enable errors on callbacks in testing. fix broken test.

2016-04-25T21:48:50+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.

Consolidate conn fixture definitions

2016-04-07T16:49:05+00:00

Use version-indexed lists for request/response protocol structs

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