summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Collapse)AuthorAgeFilesLines
* 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
|\ | | | | A simpler kafka consumer
| * 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-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
| | | | | | | | from kafka at top-level
| * Use six for py3 support in KafkaConsumerDana Powers2014-12-152-16/+42
| | | | | | | | Log connection failures w/ traceback in kafka/client.py
| * 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
| | | | | | | | configured
| * Move auto-commit checks to task_done; add support for ↵Dana Powers2014-12-151-11/+27
| | | | | | | | auto_commit_interval_messages
| * Add private methods to manage internal _msg_iterDana Powers2014-12-151-10/+20
| |
| * Reorder methods, add docstrings to public methds, section comments for ↵Dana Powers2014-12-151-207/+255
| | | | | | | | private methods
| * Use 4-space indentsDana Powers2014-12-151-518/+517
| |
| * Add docstring to get_partition_offsets; use request_time_ms and ↵Dana Powers2014-12-151-7/+25
| | | | | | | | max_num_offsets var names
| * Add docstring to configure()Dana Powers2014-12-151-0/+21
| |
| * raise KafkaConfigurationError in commit() if there is no configured ↵Dana Powers2014-12-151-1/+8
| | | | | | | | 'group_id'; add docstring
| * _should_auto_commit is privateDana Powers2014-12-151-2/+2
| |
| * Support setting offsets in set_topic_partitions(); reorganize offsets ↵Dana Powers2014-12-151-127/+151
| | | | | | | | initialization
| * _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 ↵Dana Powers2014-12-151-44/+67
| | | | | | | | list; add more type checks to set_topic_and_partitions
| * 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(); ↵Dana Powers2014-12-151-16/+35
| | | | | | | | update docstring
| * A simpler kafka consumer:Dana Powers2014-12-152-0/+439
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | ``` kafka = KafkaConsumer('topic1') for m in kafka: print m kafka = KafkaConsumer('topic1', 'topic2', group_id='my_consumer_group', auto_commit_enable=True, auto_commit_interval_ms=30 * 1000, auto_offset_reset='smallest') for m in kafka: process_message(m) kafka.task_done(m) ```
* | added a send_messages api to KeyedProducerJordan Shaw2014-12-151-0/+4
|/ | | | Signed-off-by: Jordan Shaw <jordan@pubnub.com>
* 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 #225
| * 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
|\ | | | | Improve string concatenation performance on pypy and python 3
| * 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 Consumer/Producer/Partitioner modules
| * Separate consumers/producers/partitionersDana Powers2014-09-1014-870/+947
| |
* | Merge pull request #217 from locationlabs/transactionDana Powers2014-09-101-0/+170
|\ \ | |/ |/| Commit/rollback consumer offsets via context manager
| * 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
|\ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Metadata Refactor * add MetadataRequest and MetadataResponse namedtuples * add TopicMetadata namedtuple * add error codes to Topic and Partition Metadata * add KafkaClient.send_metadata_request() method * KafkaProtocol.decode_metadata_response changed to return a MetadataResponse object so that it is consistent with server api: [broker_list, topic_list] * raise server exceptions in load_metadata_for_topics(*topics) unless topics is null (full refresh) * Replace non-standard exceptions (LeaderUnavailable, PartitionUnavailable) with server standard exceptions (LeaderNotAvailableError, UnknownTopicOrPartitionError) Conflicts: kafka/client.py test/test_client.py test/test_producer_integration.py test/test_protocol.py
View Lorry Controller Status