delta/python-packages/kafka-python.git/test/test_client_async.py, branch 1.2.5github.com: mumrah/kafka-python.git
Avoid busy poll during metadata refresh failure with retry_backoff_ms (#733)2016-06-21T02:17:49+00:00Dana Powersdana.powers@gmail.com2016-06-21T02:17:49+00:00cbcb4a6f857b5fe3609c5713ae17e30e2ae66d79
Fix socket leaks in KafkaClient (#696)2016-05-23T00:14:43+00:00Dana Powersdana.powers@gmail.com2016-05-23T00:14:43+00:0077cb35078a7408ebb0eab4bfc2220cc11c10d3b2
* 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()
* 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 names2016-04-24T23:20:22+00:00James Brownjbrown@easypost.com2016-04-11T23:52:35+00:00434802dfa17f8c9d6b17b02d12bf0f7bee6240cd
Fixes #641
Fixes #641
Use selectors module in KafkaClient2016-04-09T15:03:09+00:00Dana Powersdana.powers@gmail.com2016-04-07T23:26:22+00:00237bd730fd29a105b6aabdc0262a694fb7c8f510
Add state_change_callback to bootstrap connection2016-04-08T22:57:47+00:00Dana Powersdana.powers@gmail.com2016-04-08T22:36:18+00:00897ca399917baa178390af78870fe4be90c051d5
Move state logic from KafkaClient._maybe_connect to _conn_state_change as callback2016-04-08T22:56:24+00:00Dana Powersdana.powers@gmail.com2016-04-08T05:21:57+00:001435356cc5688df509e96eb3fb6ee4ad95732452
Split test_ready to test_is_ready2016-04-08T16:23:57+00:00Dana Powersdana.powers@gmail.com2016-04-08T05:13:00+00:004323e5c21cb151728b7985e24a1ad44fd36fd9fb
Default sleep=True in client.poll2016-04-08T16:23:57+00:00Dana Powersdana.powers@gmail.com2016-04-07T23:13:50+00:006662d1e6247f809b04a8fc7cb539a5dd02ed9b65