summaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
...
| * 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 a few basic KafkaConsumer testsDana Powers2014-12-152-13/+83
| * 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
* | Merge pull request #277 from pubnub/masterMark Roberts2014-12-161-0/+4
|\ \ | |/ |/|
| * added a send_messages api to KeyedProducerJordan Shaw2014-12-151-0/+4
|/
* Merge pull request #276 from jettify/fix-pendingMark Roberts2014-12-152-3/+15
|\
| * fix pending methodNickolai Novik2014-12-152-3/+15
|/
* Merge pull request #274 from sunisdown/masterDana Powers2014-12-111-3/+4
|\
| * update low levelsunisdown2014-12-111-3/+4
|/
* Merge pull request #268 from se7entyse7en/keyed_messageMark Roberts2014-11-265-27/+47
|\
| * Fixed TestKafkaProducerIntegrationLou Marvin Caraig2014-11-262-17/+29
| * 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
|/
* Make sure to include kafka.partitioner in setup package specDana Powers2014-09-251-0/+1
* Merge pull request #243 from wizzat/issue_241Dana Powers2014-09-231-2/+6
|\
| * Fixes issue #241, adds kafka.consumer and kafka.producer packagesMark Roberts2014-09-231-2/+6
|/
* Merge pull request #242 from wizzat/pr_225Mark Roberts2014-09-231-1/+1
|\
| * Resolve merge conflict in PR #225Mark Roberts2014-09-231-1/+1
* | Merge pull request #238 from dpkp/simple_consumer_get_messages_timeoutMark Roberts2014-09-231-4/+5
|\ \ | |/ |/|
| * 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-113-71/+91
|\
| * Use b''.join([]) instead of += to speedup codeDana Powers2014-09-103-71/+91
* | Merge pull request #232 from dpkp/directory_layoutDana Powers2014-09-1017-873/+950
|\ \ | |/ |/|
| * Separate consumers/producers/partitionersDana Powers2014-09-1017-873/+950
* | Fixup test_context.py unittest importDana Powers2014-09-101-2/+2
* | Merge pull request #217 from locationlabs/transactionDana Powers2014-09-102-0/+287
|\ \
| * | Rename KafkaTransaction to OffsetCommitContext for clarity.Jesse Myers2014-09-032-36/+36
| * | Improve documentation in exampleJesse Myers2014-08-301-1/+2
| * | Add transaction context manager.Jesse Myers2014-08-302-0/+286
* | | Update python version support in READMEDana Powers2014-09-101-4/+5
| |/ |/|
* | Add recent PR merges to Changelog for 0.9.3Dana Powers2014-09-091-0/+8
* | Bump version to 0.9.3-devDana Powers2014-09-091-1/+1
* | Merge pull request #223 from dpkp/metadata_refactorDana Powers2014-09-088-237/+479
|\ \
View Lorry Controller Status