summaryrefslogtreecommitdiff
path: root/kafka/consumer/kafka.py
Commit message (Expand)AuthorAgeFilesLines
* Remove old kafka.consumer.kafka moduleDana Powers2016-01-101-771/+0
* Fix KafkaClient->SimpleClient references0.9Dana Powers2016-01-071-2/+2
* pylint fixesDana Powers2015-12-101-1/+1
* Drop kafka_bytestringDana Powers2015-12-101-9/+7
* Convert OffsetCommit and OffsetFetch protocol encode/decodeDana Powers2015-12-101-3/+3
* Update references to kafka.common Request/Response (now Payload)Dana Powers2015-12-091-5/+6
* Merge pull request #426 from ucarion/ucarion-kafkaconsumer-closeDana Powers2015-12-061-0/+4
|\
| * Add KafkaConsumer#closeUlysse Carion2015-07-071-0/+4
* | new pylint disables for pylint 1.5.1Zack Dever2015-12-021-1/+1
* | set default config on consumer class to support subclass config changes.Zack Dever2015-08-131-2/+3
|/
* KafkaConsumer style nitsDana Powers2015-06-081-26/+48
* Update KafkaConsumer to handle request-specific FailedPayloadsErrorsDana Powers2015-06-081-11/+13
* KafkaConsumer.task_done - warn and skip messages from unrecognized topic-part...Dana Powers2015-06-061-2/+10
* Fix calling of _offsetsArturo Filastò2015-05-141-1/+1
* Use kafka_bytestring when decoding message topics in KafkaConsumer.fetch_mess...Dana Powers2015-04-041-18/+22
* Use list comprehension on _topics in KafkaConsumer.fetch_messagesDana Powers2015-04-041-8/+8
* call _consume_topic_partition() before storing offsetDana Powers2015-04-041-1/+1
* Fix python3 str/bytes bug in KafkaConsumer.set_topic_partitions({(topic, part...Dana Powers2015-04-041-1/+1
* fixup kafka consumer docstringDana Powers2015-03-291-1/+1
* Improve KafkaConsumer docstringsDana Powers2015-03-291-134/+94
* Deprecate KafkaConsumer config metadata_broker_list in favor of bootstrap_ser...Dana Powers2015-03-231-8/+26
* Merge pull request #332 from dpkp/kafka_client_editsDana Powers2015-03-071-11/+2
|\
| * Remove KafkaConsumer.BYTES_CONFIGURATION_KEYSDana Powers2015-03-011-11/+2
* | Fixes consumer/kafka and consumer/simple to only yield messages if the messag...wkiser2015-03-021-0/+4
|/
* Updated documentation for Consumers to prefer KafkaConsumer insteadJohn Anderson2015-02-091-2/+5
* Add Sphinx API docsWill Daly2015-01-151-103/+123
* Add some jitter to refresh_leader_backoff_ms, per wizzat reviewDana Powers2014-12-151-1/+7
* Simplify BYTES_CONFIGURATION_KEYS logic, per wizzat reviewDana Powers2014-12-151-2/+1
* Fixup call to self._client.get_partition_ids_for_topic -- use encoded topic b...Dana Powers2014-12-151-1/+1
* Use kafka.util.kafka_bytestring to encode utf-8 when necessaryDana Powers2014-12-151-15/+6
* OffsetCommit metadata must be bytesDana Powers2014-12-151-1/+1
* Add private methods _does_auto_commit_ms and _does_auto_commit_messagesDana Powers2014-12-151-7/+22
* Fix task_done checks when no previous commit exists; add testDana Powers2014-12-151-6/+5
* Force absolue_imports in kafka/consumer/kafka.pyDana Powers2014-12-151-0/+2
* Move KafkaConsumer to kafka.consumer.kafka module; make available for import ...Dana Powers2014-12-151-0/+723