summaryrefslogtreecommitdiff
path: root/kafka/consumer/kafka.py
Commit message (Collapse)AuthorAgeFilesLines
* Fix KafkaClient->SimpleClient references0.9Dana Powers2016-01-071-2/+2
|
* pylint fixesDana Powers2015-12-101-1/+1
| | | | | | - temporarily ignore kafka/consumer/group.py - temporarily ignore test/test_protocol.py - disable-msg deprecated; use disable= instead
* 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#close
| * Add KafkaConsumer#closeUlysse Carion2015-07-071-0/+4
| |
* | new pylint disables for pylint 1.5.1Zack Dever2015-12-021-1/+1
| | | | | | | | | | tested locally with `pylint --rcfile=pylint.rc -E kafka test`. should pass travis builds.
* | 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 ↵Dana Powers2015-06-061-2/+10
| | | | topic-partitions
* Fix calling of _offsetsArturo Filastò2015-05-141-1/+1
| | | | | | | | Previously you would see this error: ``` self.offsets._fetch[(topic, partition)], AttributeError: 'function' object has no attribute '_fetch' ```
* Use kafka_bytestring when decoding message topics in ↵Dana Powers2015-04-041-18/+22
| | | | KafkaConsumer.fetch_messages
* 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
| | | | in KafkaConsumer.set_topic_partitions((topic, partition, offset))
* Fix python3 str/bytes bug in KafkaConsumer.set_topic_partitions({(topic, ↵Dana Powers2015-04-041-1/+1
| | | | partition): offset, })
* 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 ↵Dana Powers2015-03-231-8/+26
| | | | bootstrap_servers
* Merge pull request #332 from dpkp/kafka_client_editsDana Powers2015-03-071-11/+2
|\ | | | | Kafka client edits
| * Remove KafkaConsumer.BYTES_CONFIGURATION_KEYSDana Powers2015-03-011-11/+2
| | | | | | | | | | | | - rely on KafkaClient to handle client_id string/bytes encoding - accept either string or bytes for group_id - convert group_id string to utf-8 bytes internally
* | Fixes consumer/kafka and consumer/simple to only yield messages if the ↵wkiser2015-03-021-0/+4
|/ | | | message's offset is greater than or equal to the consumer offset.
* 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 ↵Dana Powers2014-12-151-1/+1
| | | | bytes
* 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
from kafka at top-level
View Lorry Controller Status