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

Instrument metrics in BrokerConnection

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

Move kafka.selectors34 to kafka.vendor.selectors34

2016-08-01T16:56:53+00:00

Add rack to BrokerMetadata - it is always None when using MetadataRequest v0

2016-07-16T20:47:09+00:00

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

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

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

2016-06-21T02:17:49+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()

More thorough IPv6 support that uses getaddrinfo to resolve names

2016-04-24T23:20:22+00:00

Fixes #641

Use selectors module in KafkaClient

2016-04-09T15:03:09+00:00

Add state_change_callback to bootstrap connection

2016-04-08T22:57:47+00:00

Move state logic from KafkaClient._maybe_connect to _conn_state_change as callback

2016-04-08T22:56:24+00:00