summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Expand)AuthorAgeFilesLines
* 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
* 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
* Added optional argument key to create_message_set functionLou Marvin Caraig2014-11-261-4/+4
* Merge pull request #242 from wizzat/pr_225Mark Roberts2014-09-231-1/+1
|\
| * Resolve merge conflict in PR #225Mark Roberts2014-09-231-1/+1
* | Fix SimpleConsumer timeout behavior in get_messages (Issue 237)Dana Powers2014-09-211-4/+5
|/
* Merge pull request #233 from dpkp/str_join_speedupMark Roberts2014-09-111-53/+71
|\
| * Use b''.join([]) instead of += to speedup codeDana Powers2014-09-101-53/+71
* | Merge pull request #232 from dpkp/directory_layoutDana Powers2014-09-1014-870/+947
|\ \ | |/ |/|
| * Separate consumers/producers/partitionersDana Powers2014-09-1014-870/+947
* | Merge pull request #217 from locationlabs/transactionDana Powers2014-09-101-0/+170
|\ \ | |/ |/|
| * Rename KafkaTransaction to OffsetCommitContext for clarity.Jesse Myers2014-09-031-16/+16
| * Improve documentation in exampleJesse Myers2014-08-301-1/+2
| * Add transaction context manager.Jesse Myers2014-08-301-0/+169
* | Merge pull request #223 from dpkp/metadata_refactorDana Powers2014-09-085-116/+224
|\ \
| * | Add test for sending produce request to unknown topic w/o auto-creationDana Powers2014-09-011-2/+2
| * | Use standard exceptions in client._get_leader_for_partition()Dana Powers2014-09-012-19/+28
| * | Raise UnknownTopicOrPartitionError immediately in ensure_topic_exists -- serv...Dana Powers2014-09-011-0/+4
| * | load_metadata_for_topics should raise exceptions on explicit topic argsDana Powers2014-09-011-12/+40
| * | Dont need to use callbacks for offset fetch requestsDana Powers2014-09-011-4/+3
| * | Refactor internal metadata dicts in KafkaClientDana Powers2014-09-013-32/+67
| * | No more custom LeaderUnavailableError exception -- raise LeaderNotAvailableErrorDana Powers2014-09-012-7/+3
| * | if error code is not recognized in check_error: raise UnknownErrorDana Powers2014-09-011-2/+6
| * | Rearrange KafkaClient method order to group client metadata methods togetherDana Powers2014-09-011-18/+18
| * | Improve metadata protocol handlingDana Powers2014-09-013-36/+69
| |/
View Lorry Controller Status