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

	Commit message (Expand)	Author	Age	Files	Lines
*	Be explicit with tuples for %s formattinguse-explicit-tuples-for-strings	Jeff Widman	2018-11-17	4	-10/+10
*	Expose record headers in ConsumerRecords	Heikki Nousiainen	2018-09-27	1	-3/+5
*	add kerberos domain name config for gssapi sasl mechanism handshake (#1542)	the-sea	2018-08-31	1	-1/+4
*	Document connections_max_idle_ms	Jeff Widman	2018-06-26	1	-0/+5
*	Don't use `kafka.common` internally1.3.5	Jeff Widman	2018-06-05	2	-5/+5
*	Stop using deprecated log.warn()	Jeff Widman	2018-05-10	1	-3/+3
*	Fix KafkaConsumer docstring for request_timeout_ms default (#1459)	Dana Powers	2018-03-23	1	-1/+1
*	Do not validate api_version against known versions (#1434)	Dana Powers	2018-03-10	1	-2/+1
*	Avoid tight poll loop in consumer when brokers are down (#1415)	Dana Powers	2018-03-08	1	-1/+1
*	Use local copies in Fetcher._fetchable_partitions to avoid mutation errors (#...	Dana Powers	2018-03-07	1	-3/+6
*	Validate max_records in KafkaConsumer.poll (#1398)	Dana Powers	2018-02-27	1	-0/+2
*	Fix KafkaConsumer compacted offset handling (#1397)	Dana Powers	2018-02-26	1	-8/+9
*	Correctly respect timeouts in consumer poll interface (#1384)	Braedon Vickers	2018-02-21	1	-1/+1
*	use absolute imports everywhere (#1362)	Kevin Tindall	2018-02-06	3	-8/+8
*	Avoid consuming duplicate compressed messages from mid-batch (#1367)	Dana Powers	2018-02-05	1	-2/+11
*	KAFKA-3949: Avoid race condition when subscription changes during rebalance (...	Dana Powers	2018-02-02	3	-22/+24
*	Avoid KeyError when filtering fetchable partitions (#1344)	Dana Powers	2018-01-12	1	-2/+2
*	Read all available socket bytes (#1332)	Dana Powers	2018-01-10	1	-0/+2
*	KAFKA-3888 Use background thread to process consumer heartbeats (#1266)	Dana Powers	2017-12-21	2	-46/+59
*	Minor Exception cleanup	Jeff Widman	2017-12-12	1	-2/+2
*	Revert ffc7caef13a120f69788bcdd43ffa01468f575f9 / PR #1239	Dana Powers	2017-11-16	1	-7/+2
*	Use correct casing for MB	Jeff Widman	2017-11-15	2	-2/+2
*	Add DefaultRecordBatch implementation aka V2 message format parser/builder. (...	Taras Voinarovskyi	2017-10-25	1	-7/+23
*	Fix overriding sasl_kerberos_service_name in KafkaConsumer / KafkaProducer (#...	Nathanael Smith	2017-10-17	1	-0/+3
*	Fix docstring	Jeff Widman	2017-10-16	1	-3/+4
*	Merge pull request #1252 from dpkp/legacy_records_refactor	Taras Voinarovskyi	2017-10-14	1	-79/+27
\|\
\| *	Fix tests and rebase problems	Taras	2017-10-12	1	-2/+1
\| *	Remove the check for timestamp None in producer, as it's done in RecordBatch ...	Taras	2017-10-12	1	-6/+0
\| *	Refactor MessageSet and Message into LegacyRecordBatch to later support v2 me...	Taras	2017-10-11	1	-72/+27
* \|	KAFKA-4034: Avoid unnecessary consumer coordinator lookup (#1254)	Dana Powers	2017-10-11	2	-13/+31
\|/
*	Merge pull request #1245 from dpkp/KAFKA_3977_defer_fetch_parsing	Taras Voinarovskyi	2017-10-11	1	-261/+237
\|\
\| *	More testsKAFKA_3977_defer_fetch_parsing	Dana Powers	2017-10-08	1	-0/+5
\| *	Avoid sys.maxint; not supported on py3	Dana Powers	2017-10-08	1	-2/+4
\| *	KAFKA-3977: Defer fetch parsing for space efficiency, and to raise exceptions...	Dana Powers	2017-10-07	1	-261/+230
* \|	Expand metrics docs (#1243)	Jeff Widman	2017-10-08	1	-4/+11
\|/
*	Add method to ensure a valid topic name (#1238)	Niklas Mollenhauer	2017-10-07	1	-3/+28
*	Fix Fetcher.PartitionRecords to handle fetch_offset in the middle of compress...	Dana Powers	2017-10-05	1	-2/+7
*	Fix grammar	Jeff Widman	2017-10-04	1	-1/+1
*	remove beginning/end offsets request version limit	Liao Jiayi	2017-09-04	1	-8/+0
*	Remove a few unused imports (#1188)	James Lamb	2017-08-29	1	-1/+0
*	Drop unused sleep kwarg to poll (#1177)	Dana Powers	2017-08-15	2	-4/+5
*	Added unit tests for fetcher's `_reset_offset` and related functions.	Taras Voinarovskiy	2017-08-07	1	-5/+16
*	Added `beginning_offsets` and `end_offsets` API's and fixed @jeffwidman revie...	Taras Voinarovskiy	2017-08-07	2	-15/+95
*	Fix test for older brokers	Taras Voinarovskiy	2017-08-07	1	-1/+1
*	Changed retrieve_offsets to allow fetching multiple offsets at once	Taras Voinarovskiy	2017-08-07	2	-96/+133
*	Added basic support for offsets_for_times API. Still needs to group by nodes ...	Taras Voinarovskiy	2017-08-07	2	-19/+117
*	Fixed Issue 1033.Raise AssertionError when decompression unsupported. (#1159)	webber	2017-08-05	1	-0/+7
*	KIP-144: Exponential backoff for broker reconnections (#1124)	Dana Powers	2017-06-19	1	-0/+9
*	Describe consumer thread-safety	Linus Wallgren	2017-06-16	1	-0/+2
*	Follow-up to #1068: remove not-implemented comments	Dana Powers	2017-04-10	1	-1/+1