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

Add initial producer-sender metrics

2016-07-16T21:05:49+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

Test MessageSetBuffer close -- cover double close compression bug

2016-07-15T03:43:03+00:00

Avoid busy poll during metadata refresh failure with retry_backoff_ms (#733)

2016-06-21T02:17:49+00:00

Use weakref when registering a producer.close atexit to fix normal gc (#728)

2016-06-18T21:51:23+00:00

* Use weakref when registering a producer.close atexit to fix normal gc
* Test that del(producer) terminates async thread

Rearrange connection tests to separate legacy KafkaConnection

2016-06-04T23:49:38+00:00

Fix regression in MessageSet decoding wrt PartialMessages (#716)

2016-06-01T23:49:17+00:00

Fix socket leaks in KafkaClient (#696)

2016-05-23T00:14:43+00:00

* Cleanup wakeup socketpair on close to avoid leak in KafkaClient
* Cleanup unneeded bootstrap connection to avoid leak in KafkaClient
* Dont warn on socket disconnections caused by KafkaClient.close()