delta/python-packages/kafka-python.git/test, branch exclude_internal_topics github.com: mumrah/kafka-python.git Merge pull request #762 from dpkp/metadata_v1 2016-07-17T04:20:42+00:00 Dana Powers dana.powers@gmail.com 2016-07-17T04:20:42+00:00 5ab4d5c274112a4e2024dea415a0ec4b79009a28 Use Metadata Request/Response v1 with 0.10+ brokers 
Use Metadata Request/Response v1 with 0.10+ brokers
 Add initial producer-sender metrics 2016-07-16T21:05:49+00:00 Dana Powers dana.powers@gmail.com 2016-07-11T04:36:41+00:00 c34d13879641d27cceb9403a4e6617152dfda0f3 






Add rack to BrokerMetadata - it is always None when using MetadataRequest v0
2016-07-16T20:47:09+00:00

Dana Powers
dana.powers@gmail.com

2016-07-16T18:58:58+00:00

9960f3d8d2902ae0bb57262a6e530ed219168b2c












Add api_version config to KafkaClient, deprecate str in favor of tuples (#761)
2016-07-16T20:04:28+00:00

Dana Powers
dana.powers@gmail.com

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

20f4c95289c694f81a60228a9820601eb57402f4












Include zk-offset configuration in coordinator unit tests
2016-07-16T17:31:01+00:00

Dana Powers
dana.powers@gmail.com

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

061cb4e83469166873912fca2aac62ca8376377f












Fix KafkaConsumer autocommit for 0.8 brokers (#756 / #706)
2016-07-16T16:22:11+00:00

Dana Powers
dana.powers@gmail.com

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

a7000baaedc4b2e3502e3d381687a6df9ba7c2d3

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




  * 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

Dana Powers
dana.powers@gmail.com

2016-07-14T15:35:24+00:00

594f7079da4fc1598966dcc82caaf73532dea4d4












Avoid busy poll during metadata refresh failure with retry_backoff_ms (#733)
2016-06-21T02:17:49+00:00

Dana Powers
dana.powers@gmail.com

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

cbcb4a6f857b5fe3609c5713ae17e30e2ae66d79












Use weakref when registering a producer.close atexit to fix normal gc (#728)
2016-06-18T21:51:23+00:00

Dana Powers
dana.powers@gmail.com

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

6271c02c6eebf52a6d368416db49bfa57b09ef04

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




* 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

Dana Powers
dana.powers@gmail.com

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

81860eeea1449678fb2d42082e08d1bc40cf1f30