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

	Commit message (Collapse)	Author	Age	Files	Lines
*	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 ↵	Dana Powers	2016-04-08	1	-10/+24
\| \| \| \|	callback
*	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
\| \| \| \| \| \|	- merge _initiate and _finish into _maybe_connect - add connected(node_id) method - only short-circuit send() when not connected
*	Kafka IPv6 Support.	Tim Evens	2016-03-30	1	-7/+8
\| \| \| \| \| \|	IPv6 address without port can be defined as the IPv6 address. If the address is a hostname or if a port is included, then the address MUST be wrapped in brackets [] (E.g. [somehost]:1234 or [fd00:1001::2]:1234).
*	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