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

	Commit message (Expand)	Author	Age	Files	Lines
*	Expose record headers in ConsumerRecords	Heikki Nousiainen	2018-09-27	1	-3/+3
*	Don't use `kafka.common` internally1.3.5	Jeff Widman	2018-06-05	1	-2/+2
*	Fix KafkaConsumer compacted offset handling (#1397)	Dana Powers	2018-02-26	1	-2/+19
*	Avoid consuming duplicate compressed messages from mid-batch (#1367)	Dana Powers	2018-02-05	1	-0/+40
*	Revert ffc7caef13a120f69788bcdd43ffa01468f575f9 / PR #1239	Dana Powers	2017-11-16	1	-23/+0
*	Add DefaultRecordBatch implementation aka V2 message format parser/builder. (...	Taras Voinarovskyi	2017-10-25	1	-1/+1
*	Fix tests and rebase problems	Taras	2017-10-12	1	-95/+27
*	More testsKAFKA_3977_defer_fetch_parsing	Dana Powers	2017-10-08	1	-15/+195
*	Add tests for Fetcher.fetched_records and _handle_fetch_response	Dana Powers	2017-10-07	1	-14/+118
*	Fix Fetcher.PartitionRecords to handle fetch_offset in the middle of compress...	Dana Powers	2017-10-05	1	-1/+24
*	Stop using mutable types for default arg values1212-stop-using-mutable-types-for-default-arg-values	Jeff Widman	2017-09-12	1	-1/+1
*	Added unit tests for fetcher's `_reset_offset` and related functions.	Taras Voinarovskiy	2017-08-07	1	-1/+182
*	Added `max_bytes` option and FetchRequest_v3 usage. (#962)	Taras Voinarovskyi	2017-03-06	1	-1/+2
*	PEP-8: Spacing & removed unused imports (#899)	Jeff Widman	2017-02-09	1	-4/+2
*	KAFKA-3007: KafkaConsumer max_poll_records (#831)	Dana Powers	2016-09-28	1	-14/+2
*	Treat metric_group_prefix as config in KafkaConsumer	Dana Powers	2016-08-04	1	-1/+1
*	Add api_version config to KafkaClient, deprecate str in favor of tuples (#761)	Dana Powers	2016-07-16	1	-1/+1
*	Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694)	Dana Powers	2016-05-22	1	-1/+14
*	instrument metrics for fetch requests	Zack Dever	2016-04-13	1	-1/+2
*	Use version-indexed lists for request/response protocol structsprotocol_versions	Dana Powers	2016-04-05	1	-11/+13
*	Update imports from kafka.common -> kafka.errors / kafka.structs	Dana Powers	2016-04-05	1	-3/+2
*	Add Fetcher unit tests	Dana Powers	2016-01-25	1	-0/+101