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

	Commit message (Expand)	Author	Age	Files	Lines
...
*	Use python3 compatible next() in roundrobin assignor	Dana Powers	2016-01-01	1	-2/+2
*	sys.maxint not supported in python3	Dana Powers	2016-01-01	1	-4/+3
*	Use pytest instead of nose for running tests via tox	Dana Powers	2016-01-01	4	-54/+12
*	Use find_packages() for setup.py	Dana Powers	2016-01-01	1	-9/+2
*	Skeleton tests for async kafka client	Dana Powers	2016-01-01	1	-0/+103
*	Struct __eq__	Dana Powers	2016-01-01	1	-0/+7
*	Remove some unused bits from kafka.consumer.group	Dana Powers	2015-12-31	1	-5/+0
*	Improve request pipelining in consumer iterator	Dana Powers	2015-12-31	2	-13/+28
*	Fixup heartbeat config assertion	Dana Powers	2015-12-31	1	-1/+1
*	Support message decompression	Dana Powers	2015-12-31	2	-21/+40
*	Towards version 1.0	Dana Powers	2015-12-30	1	-1/+1
*	Support simple message iteration in Fetcher and new KafkaConsumer	Dana Powers	2015-12-30	2	-0/+71
*	Rename AbstractCoordinator -> BaseCoordinator, log as kafka.coordinator	Dana Powers	2015-12-30	2	-5/+5
*	Prefer assert or more-specific error to IllegalState / IllegalArgument	Dana Powers	2015-12-30	9	-69/+36
*	Catch GroupCoordinatorNotAvailableError in GroupCoordinatorResponse handler	Dana Powers	2015-12-30	1	-0/+3
*	Start test fixtures in new session to avoid propagating signals (i.e., Ctrl-C)	Dana Powers	2015-12-30	1	-0/+2
*	More Docstring Improvements	Dana Powers	2015-12-30	7	-152/+431
*	Fix blacked_out typo in least_loaded_node	Dana Powers	2015-12-30	1	-1/+1
*	BrokerConnection: wrap socket errors in retriable ConnectionError	Dana Powers	2015-12-30	1	-3/+3
*	Rename KafkaClient.connection_failed -> is_disconnected	Dana Powers	2015-12-30	2	-2/+2
*	Drop unused KafkaConsumer._ensure_not_closed method	Dana Powers	2015-12-30	1	-4/+0
*	Make group_id a Coordinator kwarg (not arg) for consistency	Dana Powers	2015-12-30	3	-8/+6
*	Improve removed tasks handing in DelayedTaskQueue.pop_ready	Dana Powers	2015-12-30	1	-2/+5
*	Remove unnecessary calls in KafkaClient._poll	Dana Powers	2015-12-30	1	-13/+13
*	Resolve delayed task futures in KafkaClient.poll	Dana Powers	2015-12-30	1	-3/+6
*	Remove unused connection_delay method from KafkaClient	Dana Powers	2015-12-30	1	-18/+0
*	Switch configs from attributes to dict to make passing / inspecting easier	Dana Powers	2015-12-29	8	-211/+211
*	Use _next_correlation_id() method to avoid int overflows	Dana Powers	2015-12-29	1	-4/+8
*	Fix log statement bug (via pylint)	Dana Powers	2015-12-29	1	-1/+1
*	Clean more ConsumerCoordinator docstrings	Dana Powers	2015-12-29	1	-16/+19
*	Catch and retry on RequestTimedOutError in producer failover test	Dana Powers	2015-12-29	1	-2/+4
*	Use ConnectionError rather than new DisconnectError	Dana Powers	2015-12-29	2	-8/+4
*	Dont warn in AutoCommitTask.disable if not previously scheduled	Dana Powers	2015-12-29	1	-1/+1
*	Improve OffsetCommit error logging	Dana Powers	2015-12-29	1	-23/+33
*	Log request failures in AbstractCoordinator._failed_request	Dana Powers	2015-12-29	1	-5/+10
*	_handle_group_coordinator_response should resolve future with the coordinator id	Dana Powers	2015-12-29	1	-1/+1
*	Improve heartbeat logging	Dana Powers	2015-12-29	1	-14/+13
*	Log as INFO: group join, leader election, partition assignments	Dana Powers	2015-12-29	2	-1/+5
*	Improve various docstrings	Dana Powers	2015-12-29	3	-22/+43
*	Remove extra raise and old TODO comment in coordinators	Dana Powers	2015-12-29	2	-2/+1
*	Make add_assigned_partition private(ish) in SubscriptionState	Dana Powers	2015-12-29	1	-3/+3
*	Make more methods private(ish) in AbstractCoordinator	Dana Powers	2015-12-29	1	-13/+13
*	Remove recursive client.poll call in ConsumerCoordinator	Dana Powers	2015-12-29	1	-2/+3
*	Pass auto commit parameters from KafkaConsumer to ConsumerCoordinator	Dana Powers	2015-12-29	2	-1/+3
*	Fix broken SubscriptionState.is_assigned call	Dana Powers	2015-12-29	1	-1/+1
*	Fix HeartbeatTask request_in_flight handling	Dana Powers	2015-12-29	1	-1/+1
*	kafka.consumer.group.KafkaConsumer: 0.9 coordinator-aware consumer	Dana Powers	2015-12-28	1	-797/+480
*	ConsumerCoordinator (based on upstream Java client)	Dana Powers	2015-12-28	4	-0/+703
*	AbstractCoordinator (modelled after upstream Java class)	Dana Powers	2015-12-28	4	-0/+690
*	Define ConsumerRebalanceListener abstract class	Dana Powers	2015-12-28	1	-0/+84