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

	Commit message (Expand)	Author	Age	Files	Lines
*	Attempt to join heartbeat thread during close() (#1735)	Dana Powers	2019-03-13	1	-3/+6
*	Ignore lookup_coordinator result in commit_offsets_async (#1712)	Faqa	2019-03-12	1	-1/+2
*	Do network connections and writes in KafkaClient.poll() (#1729)	Dana Powers	2019-03-08	1	-2/+2
*	Improve KafkaConsumer join group / only enable Heartbeat Thread during stable...	Dana Powers	2019-01-15	1	-11/+23
*	Be explicit with tuples for %s formatting	Jeff Widman	2018-11-18	1	-3/+3
*	(Attempt to) Fix deadlock between consumer and heartbeat (#1628)	Dana Powers	2018-11-10	1	-1/+1
*	Return future from commit_offsets_async (#1560)	Mike Lang	2018-08-31	1	-1/+6
*	Don't use `kafka.common` internally1.3.5	Jeff Widman	2018-06-05	2	-2/+2
*	Always acquire client lock before coordinator lock to avoid deadlocks (#1464)	Dana Powers	2018-04-18	1	-59/+64
*	Heartbeat thread start / close	Dana Powers	2018-03-23	1	-2/+4
*	Change levels for some heartbeat thread logging	Dana Powers	2018-03-23	1	-3/+3
*	Check for immediate failure when looking up coordinator in heartbeat thread (...	Dana Powers	2018-03-23	1	-1/+5
*	KAFKA-5512; Awake the heartbeat thread when timetoNextHeartbeat is equal to 0...	Dana Powers	2018-03-10	1	-0/+4
*	Remove old CommitFailed error message from coordinator (#1436)	Dana Powers	2018-03-10	1	-11/+1
*	Fix consumer poll stuck error when no available partition (#1375)	Yu Kou	2018-02-08	1	-1/+1
*	use absolute imports everywhere (#1362)	Kevin Tindall	2018-02-06	4	-23/+23
*	KAFKA-3949: Avoid race condition when subscription changes during rebalance (...	Dana Powers	2018-02-02	2	-50/+76
*	Name heartbeat thread with group_id; use backoff when polling (#1345)	Dana Powers	2018-01-16	1	-1/+1
*	Fix coordinator join_future race condition (#1338)	Dana Powers	2018-01-11	1	-4/+8
*	Improve KafkaConsumer cleanup (#1339)	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