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

	Commit message (Collapse)	Author	Age	Files	Lines
*	Use version-indexed lists for request/response protocol structsprotocol_versions	Dana Powers	2016-04-05	1	-2/+2
\|
*	KAFKA-3318: clean up consumer logging and error messages	Dana Powers	2016-04-05	1	-5/+5
\|
*	Update imports from kafka.common -> kafka.errors / kafka.structs	Dana Powers	2016-04-05	1	-2/+2
\|
*	Drop now-redundant ready() check in Fetcher._handle_offset_response	Dana Powers	2016-04-04	1	-3/+0
\|
*	Issue 545: Convert deserializer StopIteration errors to raw Exceptions	Dana Powers	2016-02-15	1	-1/+8
\|
*	KAFKA-3170: default consumer config for fetch_min_bytes should be 1	Dana Powers	2016-02-02	1	-2/+2
\|
*	Add KafkaConsumer.highwater(partition) to get highwater offsets from ↵	Dana Powers	2016-01-31	1	-1/+3
\| \| \| \|	FetchResponses
*	Fetcher iterator should check for pause and seek resets	Dana Powers	2016-01-31	1	-3/+5
\|
*	Fetcher should filter compressed messages with offsets lower than were requested	Dana Powers	2016-01-31	1	-0/+8
\|
*	Fix Fetch._create_fetch_requests docstring	Dana Powers	2016-01-25	1	-1/+1
\|
*	Ok to sleep in blocking poll for metadata update	Dana Powers	2016-01-25	1	-1/+1
\|
*	Attempt to pipeline fetchrequests in iterator	Dana Powers	2016-01-12	1	-1/+2
\|
*	Use private deque to track in-flight fetchrequests	Dana Powers	2016-01-12	1	-0/+16
\|
*	Update docstring and comments in _create_fetch_requests re KAFKA-2978	Dana Powers	2016-01-10	1	-5/+2
\|
*	Reorganize init_fetches calls during iteration	Dana Powers	2016-01-10	1	-5/+17
\| \| \| \| \| \| \|	Generally should not init_fetches while the generator has pending messages; this revision adds an explicit check / noop to the public interface, and uses a private method internally to attempt to pipeline fetch requests.
*	Check for assignment changes before yielding new record	Dana Powers	2016-01-10	1	-0/+9
\|
*	Fetcher logging should be debug or trace (left higher during testing)	Dana Powers	2016-01-10	1	-9/+11
\|
*	Fix debug logging call in PR 500	Dana Powers	2016-01-10	1	-1/+1
\|
*	KAFKA-2978: consumer stops fetching when consumed and fetch positions get ↵	Dana Powers	2016-01-10	1	-48/+38
\| \| \| \|	out of sync
*	Disable pylint error on __iter__ (next is provided via six.Iterator)	Dana Powers	2016-01-03	1	-1/+1
\|
*	Batched message methods now return dict of lists	Dana Powers	2016-01-02	1	-2/+2
\|
*	Improve iterator interface	Dana Powers	2016-01-02	1	-6/+22
\| \| \| \| \| \| \| \|	- Support single message consumption via next(consumer) in py2/py3 - batch message methods (Fetcher.fetched_records / KafkaConsumer.poll) are incompatible with iterators -- message generator state keeps messages internally after they are popped from _records, but before subscription_state is updated.
*	Improve request pipelining in consumer iterator	Dana Powers	2015-12-31	1	-13/+25
\|
*	Support message decompression	Dana Powers	2015-12-31	1	-19/+15
\|
*	Support simple message iteration in Fetcher and new KafkaConsumer	Dana Powers	2015-12-30	1	-0/+49
\|
*	Prefer assert or more-specific error to IllegalState / IllegalArgument	Dana Powers	2015-12-30	1	-13/+7
\|
*	More Docstring Improvements	Dana Powers	2015-12-30	1	-39/+94
\|
*	Switch configs from attributes to dict to make passing / inspecting easier	Dana Powers	2015-12-29	1	-25/+25
\|
*	New class: kafka.consumer.fetcher.Fetcher	Dana Powers	2015-12-28	1	-0/+523
	- manages fetch requests via async client and subscription_state - based on upstream java client