delta/python-packages/kafka-python.git - github.com: mumrah/kafka-python.git

	Commit message (Expand)	Author	Age	Files	Lines
*	Send socket data via non-blocking IO with send buffer (#1912)	Dana Powers	2019-09-29	1	-1/+3
*	Rely on socket selector to detect completed connection attempts (#1909)	Dana Powers	2019-09-28	1	-1/+1
*	Reduce client poll timeout when no ifrs	Dana Powers	2019-05-29	1	-0/+12
*	Remove unused imports (#1808)	Jeff Widman	2019-05-22	1	-5/+1
*	Do not call state_change_callback with lock (#1775)	Dana Powers	2019-04-02	1	-10/+11
*	Dont treat popped conn.close() as failure in state change callback (#1773)	Dana Powers	2019-04-01	1	-2/+3
*	Dont wakeup during maybe_refresh_metadata -- it is only called by poll() (#1769)	Dana Powers	2019-03-30	1	-2/+2
*	Retry bootstrapping after backoff when necessary (#1736)	Dana Powers	2019-03-14	1	-45/+23
*	Recheck connecting nodes sooner when refreshing metadata (#1737)	Dana Powers	2019-03-13	1	-1/+1
*	Do network connections and writes in KafkaClient.poll() (#1729)	Dana Powers	2019-03-08	1	-5/+4
*	Don't use `kafka.common` internally1.3.5	Jeff Widman	2018-06-05	1	-2/+1
*	Add BrokerConnection.connect_blocking() (#1411)	Dana Powers	2018-03-09	1	-3/+5
*	KAFKA-3888 Use background thread to process consumer heartbeats (#1266)	Dana Powers	2017-12-21	1	-11/+0
*	Drop unused sleep kwarg to poll (#1177)	Dana Powers	2017-08-15	1	-17/+16
*	Timeout idle connections via connections_max_idle_ms (#1068)	Dana Powers	2017-04-10	1	-2/+36
*	Avoid multiple connection attempts when refreshing metadata (#1067)	Dana Powers	2017-04-05	1	-14/+25
*	Derive all api classes from Request / Response base classes (#1030)	Dana Powers	2017-03-14	1	-2/+3
*	Spelling and grammar changes (#923)	melissacrawford396	2017-01-11	1	-1/+1
*	Add metadata update to pattern subscribing (#915)	Dmitry Lazurkin	2016-12-27	1	-2/+26
*	Instrument metrics in BrokerConnection	Dana Powers	2016-08-04	1	-0/+2
*	Move kafka.selectors34 to kafka.vendor.selectors34	Dana Powers	2016-08-01	1	-1/+1
*	Add rack to BrokerMetadata - it is always None when using MetadataRequest v0	Dana Powers	2016-07-16	1	-2/+2
*	Add api_version config to KafkaClient, deprecate str in favor of tuples (#761)	Dana Powers	2016-07-16	1	-92/+48
*	Avoid busy poll during metadata refresh failure with retry_backoff_ms (#733)	Dana Powers	2016-06-20	1	-2/+100
*	Fix socket leaks in KafkaClient (#696)	Dana Powers	2016-05-22	1	-3/+6
*	More thorough IPv6 support that uses getaddrinfo to resolve names	James Brown	2016-04-24	1	-7/+7
*	Use selectors module in KafkaClientselectors	Dana Powers	2016-04-09	1	-1/+14
*	Add state_change_callback to bootstrap connectionconn_state_callback	Dana Powers	2016-04-08	1	-2/+8
*	Move state logic from KafkaClient._maybe_connect to _conn_state_change as cal...	Dana Powers	2016-04-08	1	-10/+24
*	Split test_ready to test_is_ready	Dana Powers	2016-04-08	1	-34/+21
*	Default sleep=True in client.poll	Dana Powers	2016-04-08	1	-4/+4
*	Add BrokerConnection.disconnected() method; update tests	Dana Powers	2016-04-08	1	-6/+5
*	Consolidate conn fixture definitions	Dana Powers	2016-04-07	1	-15/+0
*	Use version-indexed lists for request/response protocol structsprotocol_versions	Dana Powers	2016-04-05	1	-4/+4
*	Update imports from kafka.common -> kafka.errors / kafka.structs	Dana Powers	2016-04-05	1	-2/+2
*	Improve KafkaClient connect and ready handlingnode_not_ready	Dana Powers	2016-04-04	1	-44/+40
*	Kafka IPv6 Support.	Tim Evens	2016-03-30	1	-7/+8
*	Fix client poll tests (called with sleep=False)	Dana Powers	2016-01-23	1	-4/+5
*	Fix delayed_task timeout commit 45d26b6	Dana Powers	2016-01-10	1	-3/+3
*	Check delayed task timeout in client.poll()	Dana Powers	2016-01-10	1	-2/+28
*	Fill out more async client unit tests	Dana Powers	2016-01-09	1	-18/+165
*	Use parameterized pytests in test_client_async; add pytest-mocker plugin	Dana Powers	2016-01-03	1	-70/+94
*	Skeleton tests for async kafka client	Dana Powers	2016-01-01	1	-0/+103