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

	Commit message (Expand)	Author	Age	Files	Lines
*	Cover sticky assignor's metadata method with tests (#2161)	Valeria Chernenko	2020-11-05	1	-3/+7
*	Use six.viewitems instead of six.iteritems to avoid encoding problems (#2154)	Valeria Chernenko	2020-10-30	1	-1/+1
*	KIP-54: Implement sticky partition assignment strategy (#2057)	Valeria Chernenko	2020-09-29	5	-1/+897
*	Fix #1985: fix consumer deadlock when heartbeat thread request timeout (#2064)	huangcuiyang	2020-09-07	1	-8/+12
*	remove unused imports	James Lamb	2020-07-10	1	-1/+0
*	Optionally return OffsetAndMetadata from consumer.committed(tp) (#1979)	Dana Powers	2019-12-29	1	-3/+3
*	Log retriable coordinator NodeNotReady, TooManyInFlightRequests as debug not ...	Dana Powers	2019-12-29	1	-2/+5
*	Fix simple typo: managementment -> management	Tim Gates	2019-12-08	1	-1/+1
*	Fix typos	Carson Ip	2019-11-08	1	-1/+1
*	Issue #1780 - Consumer hang indefinitely in fetcher._retrieve_offsets() due t...	Commander Dishwasher	2019-09-30	1	-1/+5
*	Change coordinator lock acquisition order (#1821)	Dana Powers	2019-09-29	1	-42/+36
*	Wrap consumer.poll() for KafkaConsumer iteration (#1902)	Dana Powers	2019-09-28	1	-1/+5
*	Allow the coordinator to auto-commit for all api_version.	Jay Chan	2019-06-20	1	-1/+1
*	Use dedicated connection for group coordinator (#1822)	Dana Powers	2019-06-19	1	-3/+3
*	A little python cleanup (#1805)	Jeff Widman	2019-05-17	1	-4/+2
*	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