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

	Commit message (Expand)	Author	Age	Files	Lines
*	KIP-54: Implement sticky partition assignment strategy (#2057)	Valeria Chernenko	2020-09-29	1	-9/+27
*	Use ==/!= to compare str, bytes, and int literals	Christian Clauss	2020-02-05	1	-1/+1
*	Optionally return OffsetAndMetadata from consumer.committed(tp) (#1979)	Dana Powers	2019-12-29	1	-2/+2
*	Don't use `kafka.common` internally1.3.5	Jeff Widman	2018-06-05	1	-3/+3
*	KAFKA-3949: Avoid race condition when subscription changes during rebalance (...	Dana Powers	2018-02-02	1	-37/+21
*	Minor test cleanups (#1343)	Dana Powers	2018-01-12	1	-0/+1
*	Fix coordinator join_future race condition (#1338)	Dana Powers	2018-01-11	1	-0/+13
*	KAFKA-3888 Use background thread to process consumer heartbeats (#1266)	Dana Powers	2017-12-21	1	-39/+61
*	Handle lookup_coordinator send failures (#1279)	Dana Powers	2017-10-24	1	-0/+8
*	KAFKA-4034: Avoid unnecessary consumer coordinator lookup (#1254)	Dana Powers	2017-10-11	1	-5/+4
*	Treat metric_group_prefix as config in KafkaConsumer	Dana Powers	2016-08-04	1	-4/+3
*	KAFKA-3486: fix autocommit when partitions assigned manually (#767 / #626)	Dana Powers	2016-07-17	1	-5/+0
*	KAFKA-3117: handle metadata updates during consumer rebalance (#766 / #701)	Dana Powers	2016-07-17	1	-1/+1
*	Add api_version config to KafkaClient, deprecate str in favor of tuples (#761)	Dana Powers	2016-07-16	1	-13/+14
*	Include zk-offset configuration in coordinator unit tests	Dana Powers	2016-07-16	1	-2/+6
*	Fix KafkaConsumer autocommit for 0.8 brokers (#756 / #706)	Dana Powers	2016-07-16	1	-3/+2
*	enable errors on callbacks in testing. fix broken test.	Zack Dever	2016-04-25	1	-1/+1
*	Beginnings of metrics instrumentation in kafka consumer.	Zack Dever	2016-04-13	1	-6/+13
*	Consolidate conn fixture definitions	Dana Powers	2016-04-07	1	-13/+0
*	Use version-indexed lists for request/response protocol structsprotocol_versions	Dana Powers	2016-04-05	1	-34/+33
*	KAFKA-3318: clean up consumer logging and error messages	Dana Powers	2016-04-05	1	-3/+3
*	Update imports from kafka.common -> kafka.errors / kafka.structs	Dana Powers	2016-04-05	1	-3/+2
*	Test _maybe_auto_commit_offsets_sync when group_id is None	Dana Powers	2016-04-03	1	-19/+35
*	Add test for unknown coordinator heartbeat task	Dana Powers	2016-03-12	1	-2/+14
*	Mock client.ready() call to test coordinator offset fetch request	Dana Powers	2016-02-19	1	-0/+1
*	break up some circular references and close client wake pipe on __del__	aisch	2016-02-16	1	-1/+2
*	Add RangePartitionAssignor (and use as default); add assignor testsrange_assignor	Dana Powers	2016-02-16	1	-7/+11
*	Add mocking to test_coordinator::test_close to fix random test failure (via t...	Dana Powers	2016-01-11	1	-0/+1
*	Add ConsumerCoordinator unit tests	Dana Powers	2016-01-10	1	-0/+568