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

	Commit message (Expand)	Author	Age	Files	Lines
*	Update to 0.11.0.1 for travis test fixture; use as default if unspecified (#1...	Dana Powers	2017-10-08	1	-1/+1
*	Add method to ensure a valid topic name (#1238)	Niklas Mollenhauer	2017-10-07	1	-0/+25
*	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	4	-4/+4
*	remove beginning/end offsets request version limit	Liao Jiayi	2017-09-04	1	-6/+0
*	Drop unused sleep kwarg to poll (#1177)	Dana Powers	2017-08-15	1	-17/+16
*	Added unit tests for fetcher's `_reset_offset` and related functions.	Taras Voinarovskiy	2017-08-07	2	-2/+183
*	Added `beginning_offsets` and `end_offsets` API's and fixed @jeffwidman revie...	Taras Voinarovskiy	2017-08-07	1	-1/+46
*	Changed retrieve_offsets to allow fetching multiple offsets at once	Taras Voinarovskiy	2017-08-07	1	-4/+41
*	Fix test for older brokers	Taras Voinarovskiy	2017-08-07	1	-2/+4
*	Added basic support for offsets_for_times API. Still needs to group by nodes ...	Taras Voinarovskiy	2017-08-07	1	-1/+45
*	Fix typo	Jeff Widman	2017-07-01	1	-1/+1
*	Do not test fetched_size with fetch_max_bytes since 0.11 brokers will return ...	Dana Powers	2017-06-18	1	-3/+0
*	Increase max_buffer_size for test_large_messages	Dana Powers	2017-06-18	1	-2/+8
*	Fix fetch_max_bytes=1 consumer integration test	Dana Powers	2017-06-18	1	-10/+10
*	Use fixture hostname (dont assume localhost)	Dana Powers	2017-06-18	2	-2/+2
*	Timeout idle connections via connections_max_idle_ms (#1068)	Dana Powers	2017-04-10	1	-2/+36
*	Avoid multiple connection attempts when refreshing metadata (#1067)	Dana Powers	2017-04-05	1	-14/+25
*	Derive all api classes from Request / Response base classes (#1030)	Dana Powers	2017-03-14	2	-4/+6
*	Alter test skips: python-lz4 works on python26, but not pypy	Dana Powers	2017-03-14	3	-7/+14
*	Avoid re-encoding for message crc check (#1027)	Dana Powers	2017-03-13	1	-0/+24
*	Return copy of consumer subscription set (#1029)	Dana Powers	2017-03-13	1	-0/+8
*	Fix kwarg handing in kafka.protocol.struct.Struct (#1025)	Dana Powers	2017-03-09	1	-1/+15
*	Fix integration test that requires consumer group	Dana Powers	2017-03-07	1	-1/+4
*	Disable default consumer group (#1016)	Dana Powers	2017-03-06	1	-0/+2
*	Added `max_bytes` option and FetchRequest_v3 usage. (#962)	Taras Voinarovskyi	2017-03-06	2	-1/+48
*	Remove dead code (#967)	Jeff Widman	2017-02-28	1	-46/+0
*	Fail-fast on timeout constraint violations during KafkaConsumer creation (#986)	Harel Ben-Attia	2017-02-28	1	-0/+8
*	Drop bad disconnect test -- just use the mocked-socket test (#982)	Dana Powers	2017-02-24	1	-27/+1
*	PEP-8: Spacing & removed unused imports (#899)	Jeff Widman	2017-02-09	1	-4/+2
*	Spelling and grammar changes (#923)	melissacrawford396	2017-01-11	2	-2/+2
*	Update pytest fixtures to new yield syntax (#919)	Jeff Widman	2017-01-11	2	-10/+6
*	Add metadata update to pattern subscribing (#915)	Dmitry Lazurkin	2016-12-27	1	-2/+26
*	When hostname lookup is necessary, do every connect (#812)	Evan Bender	2016-11-20	1	-0/+28
*	Fix typos	Jeff Widman	2016-11-14	3	-3/+3
*	Fix murmur2 bug handling python2 bytes that do not ascii encode (#815)	Dana Powers	2016-10-22	1	-15/+9
*	KAFKA-3007: KafkaConsumer max_poll_records (#831)	Dana Powers	2016-09-28	3	-22/+3
*	Update Partitioners for use with KafkaProducer (#827)	barrotsteindev	2016-09-28	1	-0/+33
*	Dump fixture logs on failure	Dana Powers	2016-08-04	1	-0/+2
*	Try to bind to a new port on fixture failure retries	Dana Powers	2016-08-04	1	-29/+21
*	Change coordinator.needs_join_prepare -> coordinator.rejoining; fix consumer ...	Dana Powers	2016-08-04	1	-1/+6
*	Instrument metrics in BrokerConnection	Dana Powers	2016-08-04	1	-0/+2
*	Treat metric_group_prefix as config in KafkaConsumer	Dana Powers	2016-08-04	2	-5/+4
*	Always absolute_importabsolute_import	Dana Powers	2016-08-02	4	-0/+8
*	Move kafka.selectors34 to kafka.vendor.selectors34	Dana Powers	2016-08-01	1	-1/+1
*	Always encode size with MessageSet (#771)	Dana Powers	2016-07-17	1	-2/+2
*	Catch select errors while capturing test fixture logs	Dana Powers	2016-07-17	1	-1/+7
*	Delete KafkaConnection class (#769)	Dana Powers	2016-07-17	1	-210/+0
*	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