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

	Commit message (Expand)	Author	Age	Files	Lines
*	Improve KafkaConsumer cleanupreference_cleanup_close	Dana Powers	2018-01-10	2	-11/+28
*	KAFKA-3888 Use background thread to process consumer heartbeats (#1266)	Dana Powers	2017-12-21	3	-350/+615
*	Replace periods (java) with underscores (python)	Jeff Widman	2017-11-07	1	-2/+2
*	Handle lookup_coordinator send failures (#1279)	Dana Powers	2017-10-24	1	-5/+11
*	KAFKA-4034: Avoid unnecessary consumer coordinator lookup (#1254)	Dana Powers	2017-10-11	2	-8/+43
*	Explicitly check for `None` rather than False	Jeff Widman	2017-10-06	1	-1/+1
*	Initialize metadata_snapshot in group coordinator (#1174)	Dana Powers	2017-08-13	1	-6/+9
*	Use for join-time-max and sync-time-max metrics Max() measure function (#1146)	Alexey Pervushin	2017-07-20	1	-2/+2
*	change_subscription called only when necessary (#1132)	Petr Šebek	2017-07-07	1	-2/+3
*	Backoff on unavailable group coordinator retry (#1125)	Dana Powers	2017-06-19	1	-0/+2
*	Additional docstrings for autocommit close option	Dana Powers	2017-03-13	2	-2/+10
*	Optionally skip auto-commit during consumer.close (#1031)	Dana Powers	2017-03-13	1	-2/+3
*	Short-circuit group coordinator requests when NodeNotReady (#995)	Dana Powers	2017-03-09	1	-0/+23
*	Avoid unknown coordinator after client poll (#1023)	Dana Powers	2017-03-09	1	-7/+6
*	For 0.8.2, only attempt connection to coordinator if least_loaded_node succeeds	Dana Powers	2017-03-07	1	-1/+2
*	Minor additional logging for consumer coordinator	Dana Powers	2017-03-06	1	-0/+2
*	Dont refresh metadata on failed group coordinator request unless needed (#1006)	Dana Powers	2017-03-03	1	-6/+4
*	Add sphinx formatting to hyperlink methods (#898)	Jeff Widman	2017-03-03	1	-5/+5
*	PEP-8: Spacing & removed unused imports (#899)	Jeff Widman	2017-02-09	1	-6/+6
*	Fix possible request draining in ensure_active_group (#896)	Dana Powers	2016-12-02	1	-3/+6
*	Always include an error for logging when the coordinator is marked dead (#890)	Dana Powers	2016-11-18	2	-9/+9
*	Add comment for round robin partitioner with different subscriptions	Dana Powers	2016-08-20	1	-0/+15
*	Drain pending requests to the coordinator before initiating group rejoin (#798)	Dana Powers	2016-08-04	1	-0/+8
*	Change coordinator.needs_join_prepare -> coordinator.rejoining; fix consumer ...	Dana Powers	2016-08-04	1	-4/+4
*	Treat metric_group_prefix as config in KafkaConsumer	Dana Powers	2016-08-04	2	-8/+7
*	Always absolute_importabsolute_import	Dana Powers	2016-08-02	4	-0/+8
*	Vendor six 1.10.0six	Dana Powers	2016-08-01	4	-4/+4
*	Add base coordinator metrics	Dana Powers	2016-07-17	3	-76/+80
*	KAFKA-3486: fix autocommit when partitions assigned manually (#767 / #626)	Dana Powers	2016-07-17	1	-44/+8
*	KAFKA-3117: handle metadata updates during consumer rebalance (#766 / #701)	Dana Powers	2016-07-17	1	-10/+24
*	KAFKA-2832: Add a consumer config option to exclude internal topics (#765)	Dana Powers	2016-07-17	1	-4/+8
*	Fix KafkaConsumer autocommit for 0.8 brokers (#756 / #706)	Dana Powers	2016-07-16	2	-20/+25
*	Avoid some exceptions in Coordinator.__del__ (#668)	Dana Powers	2016-04-25	2	-2/+4
*	Changing some commented out metrics to avoid future gotchas.	Zack Dever	2016-04-13	1	-3/+3
*	Beginnings of metrics instrumentation in kafka consumer.	Zack Dever	2016-04-13	1	-41/+30
*	Default sleep=True in client.poll	Dana Powers	2016-04-08	1	-1/+1
*	Can no longer have coordinator_id if coordinator_unknown()	Dana Powers	2016-04-08	1	-6/+0
*	Use version-indexed lists for request/response protocol structsprotocol_versions	Dana Powers	2016-04-05	2	-24/+21
*	Remove unused importskafka-3318	Dana Powers	2016-04-05	1	-2/+0
*	KAFKA-3318: clean up consumer logging and error messages	Dana Powers	2016-04-05	2	-78/+103
*	Update imports from kafka.common -> kafka.errors / kafka.structs	Dana Powers	2016-04-05	4	-5/+5
*	Merge pull request #589 from dpkp/node_not_ready	Dana Powers	2016-04-04	1	-8/+14
\|\
\| *	Improve Coordinator Error handling	Dana Powers	2016-04-04	1	-8/+14
* \|	Improve auto-commit task handling when group_id is Noneissue_619	Dana Powers	2016-04-03	1	-20/+22
\|/
*	Check for None returned from least_loaded_node when no brokers are availablenone_least_loaded_node	Dana Powers	2016-03-13	1	-0/+4
*	Log successful heartbeat as INFO; improve heartbeat response logging	Dana Powers	2016-03-12	1	-11/+12
*	HeartbeatTask should reschedule heartbeat on coordinator_unknown()	Dana Powers	2016-03-12	1	-2/+6
*	Mock client.ready() call to test coordinator offset fetch request	Dana Powers	2016-02-19	1	-1/+2
*	Some attributes may not exist in __del__ if we failed assertions	Dana Powers	2016-02-18	1	-1/+1
*	More friendly warning when offset fetch request returns unknown topic / parti...	Dana Powers	2016-02-18	1	-1/+2