summaryrefslogtreecommitdiff
path: root/kafka/consumer/fetcher.py
Commit message (Expand)AuthorAgeFilesLines
* Fix debug logging call in PR 500Dana Powers2016-01-101-1/+1
* KAFKA-2978: consumer stops fetching when consumed and fetch positions get out...Dana Powers2016-01-101-48/+38
* Disable pylint error on __iter__ (next is provided via six.Iterator)Dana Powers2016-01-031-1/+1
* Batched message methods now return dict of listsDana Powers2016-01-021-2/+2
* Improve iterator interfaceDana Powers2016-01-021-6/+22
* Improve request pipelining in consumer iteratorDana Powers2015-12-311-13/+25
* Support message decompressionDana Powers2015-12-311-19/+15
* Support simple message iteration in Fetcher and new KafkaConsumerDana Powers2015-12-301-0/+49
* Prefer assert or more-specific error to IllegalState / IllegalArgumentDana Powers2015-12-301-13/+7
* More Docstring ImprovementsDana Powers2015-12-301-39/+94
* Switch configs from attributes to dict to make passing / inspecting easierDana Powers2015-12-291-25/+25
* New class: kafka.consumer.fetcher.FetcherDana Powers2015-12-281-0/+523