summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Expand)AuthorAgeFilesLines
* Fix python2.6 threading.Event bug in ReentrantTimerDana Powers2015-02-031-1/+5
* Merge pull request #306 from sontek/catch_topic_not_bytesMark Roberts2015-02-021-1/+7
|\
| * Just encode to bytes if it isn't bytes.John Anderson2015-01-241-2/+4
| * Alert if the topic is not sent as bytesJohn Anderson2015-01-231-0/+4
* | fix circle referencezhaopengzp2015-02-021-0/+1
|/
* Merge pull request #282 from wedaly/sphinx-api-docsDana Powers2015-01-2314-312/+357
|\
| * Add Sphinx API docsWill Daly2015-01-1514-312/+357
* | Catch ReplicaNotAvailableError in MetadataResponse -- per kafka-devs, this er...Dana Powers2015-01-141-1/+6
* | Merge pull request #289 from alexcb/broker-error-class-refactoringDana Powers2015-01-121-24/+12
|\ \
| * | Use reflection to avoid multiple errno definitionsAlex Couture-Beil2015-01-101-24/+12
| |/
* | Merge pull request #286 from Dinoshauer/expose-KafkaConsumer-in-allDana Powers2015-01-121-1/+1
|\ \
| * | KafkaConsumer should be in __all__.Kasper Jacobsen2015-01-091-1/+1
| |/
* | Randomize start by default for SimpleProducerAlex Couture-Beil2015-01-091-1/+1
|/
* Added keys to compressed messages (both gzip and snappy).Eric Hewitt2015-01-021-2/+2
* Merge pull request #234 from dpkp/high_level_consumerMark Roberts2014-12-166-5/+764
|\
| * 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-152-15/+18
| * 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-153-4/+5
| * Use six for py3 support in KafkaConsumerDana Powers2014-12-152-16/+42
| * Update docstrings w/ current interface / config defaultsDana Powers2014-12-151-16/+21
| * Raise KafkaConfigurationError during fetch_messages if not topics/partitions ...Dana Powers2014-12-151-1/+7
| * Move auto-commit checks to task_done; add support for auto_commit_interval_me...Dana Powers2014-12-151-11/+27
| * Add private methods to manage internal _msg_iterDana Powers2014-12-151-10/+20
| * Reorder methods, add docstrings to public methds, section comments for privat...Dana Powers2014-12-151-207/+255
| * Use 4-space indentsDana Powers2014-12-151-518/+517
| * Add docstring to get_partition_offsets; use request_time_ms and max_num_offse...Dana Powers2014-12-151-7/+25
| * Add docstring to configure()Dana Powers2014-12-151-0/+21
| * raise KafkaConfigurationError in commit() if there is no configured 'group_id...Dana Powers2014-12-151-1/+8
| * _should_auto_commit is privateDana Powers2014-12-151-2/+2
| * Support setting offsets in set_topic_partitions(); reorganize offsets initial...Dana Powers2014-12-151-127/+151
| * _client is private varDana Powers2014-12-151-7/+11
| * Move kafka._msg_iter initialization from __init__() to next()Dana Powers2014-12-151-6/+7
| * self._topics is private; fixup topic iterations for new TopicAndPartition lis...Dana Powers2014-12-151-44/+67
| * Add set_topic_partitions method to configure topics/partitions to consumeDana Powers2014-12-151-8/+59
| * Use client.get_partition_ids_for_topicDana Powers2014-12-151-4/+4
| * Use configure() to check and set configuration keysDana Powers2014-12-152-59/+71
| * add private methods _set_consumer_timeout_start() and _check_consumer_timeout()Dana Powers2014-12-151-8/+13
| * Handle FailedPayloadsError on client.send_fetch_request; permit offsets(); up...Dana Powers2014-12-151-16/+35
| * A simpler kafka consumer:Dana Powers2014-12-152-0/+439
* | added a send_messages api to KeyedProducerJordan Shaw2014-12-151-0/+4
|/
* fix pending methodNickolai Novik2014-12-151-1/+1
* Added raise of TypeError for non bytes keyLou Marvin Caraig2014-11-261-1/+6
* Key is passed when creating messages for both async=False and async=TrueLou Marvin Caraig2014-11-262-6/+7
* Added private method _send_messages that can accept kwargsLou Marvin Caraig2014-11-261-0/+2
View Lorry Controller Status