Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Fix python2.6 threading.Event bug in ReentrantTimer | Dana Powers | 2015-02-03 | 1 | -1/+5 |
| | |||||
* | Merge pull request #306 from sontek/catch_topic_not_bytes | Mark Roberts | 2015-02-02 | 1 | -1/+7 |
|\ | | | | | Alert if the topic is not sent as bytes | ||||
| * | Just encode to bytes if it isn't bytes. | John Anderson | 2015-01-24 | 1 | -2/+4 |
| | | |||||
| * | Alert if the topic is not sent as bytes | John Anderson | 2015-01-23 | 1 | -0/+4 |
| | | |||||
* | | fix circle reference | zhaopengzp | 2015-02-02 | 1 | -0/+1 |
|/ | |||||
* | Merge pull request #282 from wedaly/sphinx-api-docs | Dana Powers | 2015-01-23 | 14 | -312/+357 |
|\ | | | | | Add Sphinx API docs | ||||
| * | Add Sphinx API docs | Will Daly | 2015-01-15 | 14 | -312/+357 |
| | | |||||
* | | Catch ReplicaNotAvailableError in MetadataResponse -- per kafka-devs, this ↵ | Dana Powers | 2015-01-14 | 1 | -1/+6 |
| | | | | | | | | error can and should be ignored | ||||
* | | Merge pull request #289 from alexcb/broker-error-class-refactoring | Dana Powers | 2015-01-12 | 1 | -24/+12 |
|\ \ | | | | | | | Use reflection to avoid multiple errno definitions | ||||
| * | | Use reflection to avoid multiple errno definitions | Alex Couture-Beil | 2015-01-10 | 1 | -24/+12 |
| |/ | |||||
* | | Merge pull request #286 from Dinoshauer/expose-KafkaConsumer-in-all | Dana Powers | 2015-01-12 | 1 | -1/+1 |
|\ \ | | | | | | | KafkaConsumer should be in __all__. | ||||
| * | | KafkaConsumer should be in __all__. | Kasper Jacobsen | 2015-01-09 | 1 | -1/+1 |
| |/ | |||||
* | | Randomize start by default for SimpleProducer | Alex Couture-Beil | 2015-01-09 | 1 | -1/+1 |
|/ | | | | | | | | random_start=False is dangerous. Any client that initializes a SimpleProducer and performs only a single publish batch will always go to partition 0. A common use-case for this is command line utilities, or web-servers which are unable to cache the SimpleProducer instance between calls. | ||||
* | Added keys to compressed messages (both gzip and snappy). | Eric Hewitt | 2015-01-02 | 1 | -2/+2 |
| | |||||
* | Merge pull request #234 from dpkp/high_level_consumer | Mark Roberts | 2014-12-16 | 6 | -5/+764 |
|\ | | | | | A simpler kafka consumer | ||||
| * | Add some jitter to refresh_leader_backoff_ms, per wizzat review | Dana Powers | 2014-12-15 | 1 | -1/+7 |
| | | |||||
| * | Simplify BYTES_CONFIGURATION_KEYS logic, per wizzat review | Dana Powers | 2014-12-15 | 1 | -2/+1 |
| | | |||||
| * | Fixup call to self._client.get_partition_ids_for_topic -- use encoded topic ↵ | Dana Powers | 2014-12-15 | 1 | -1/+1 |
| | | | | | | | | bytes | ||||
| * | Use kafka.util.kafka_bytestring to encode utf-8 when necessary | Dana Powers | 2014-12-15 | 2 | -15/+18 |
| | | |||||
| * | OffsetCommit metadata must be bytes | Dana Powers | 2014-12-15 | 1 | -1/+1 |
| | | |||||
| * | Add private methods _does_auto_commit_ms and _does_auto_commit_messages | Dana Powers | 2014-12-15 | 1 | -7/+22 |
| | | |||||
| * | Fix task_done checks when no previous commit exists; add test | Dana Powers | 2014-12-15 | 1 | -6/+5 |
| | | |||||
| * | Force absolue_imports in kafka/consumer/kafka.py | Dana Powers | 2014-12-15 | 1 | -0/+2 |
| | | |||||
| * | Move KafkaConsumer to kafka.consumer.kafka module; make available for import ↵ | Dana Powers | 2014-12-15 | 3 | -4/+5 |
| | | | | | | | | from kafka at top-level | ||||
| * | Use six for py3 support in KafkaConsumer | Dana Powers | 2014-12-15 | 2 | -16/+42 |
| | | | | | | | | Log connection failures w/ traceback in kafka/client.py | ||||
| * | Update docstrings w/ current interface / config defaults | Dana Powers | 2014-12-15 | 1 | -16/+21 |
| | | |||||
| * | Raise KafkaConfigurationError during fetch_messages if not topics/partitions ↵ | Dana Powers | 2014-12-15 | 1 | -1/+7 |
| | | | | | | | | configured | ||||
| * | Move auto-commit checks to task_done; add support for ↵ | Dana Powers | 2014-12-15 | 1 | -11/+27 |
| | | | | | | | | auto_commit_interval_messages | ||||
| * | Add private methods to manage internal _msg_iter | Dana Powers | 2014-12-15 | 1 | -10/+20 |
| | | |||||
| * | Reorder methods, add docstrings to public methds, section comments for ↵ | Dana Powers | 2014-12-15 | 1 | -207/+255 |
| | | | | | | | | private methods | ||||
| * | Use 4-space indents | Dana Powers | 2014-12-15 | 1 | -518/+517 |
| | | |||||
| * | Add docstring to get_partition_offsets; use request_time_ms and ↵ | Dana Powers | 2014-12-15 | 1 | -7/+25 |
| | | | | | | | | max_num_offsets var names | ||||
| * | Add docstring to configure() | Dana Powers | 2014-12-15 | 1 | -0/+21 |
| | | |||||
| * | raise KafkaConfigurationError in commit() if there is no configured ↵ | Dana Powers | 2014-12-15 | 1 | -1/+8 |
| | | | | | | | | 'group_id'; add docstring | ||||
| * | _should_auto_commit is private | Dana Powers | 2014-12-15 | 1 | -2/+2 |
| | | |||||
| * | Support setting offsets in set_topic_partitions(); reorganize offsets ↵ | Dana Powers | 2014-12-15 | 1 | -127/+151 |
| | | | | | | | | initialization | ||||
| * | _client is private var | Dana Powers | 2014-12-15 | 1 | -7/+11 |
| | | |||||
| * | Move kafka._msg_iter initialization from __init__() to next() | Dana Powers | 2014-12-15 | 1 | -6/+7 |
| | | |||||
| * | self._topics is private; fixup topic iterations for new TopicAndPartition ↵ | Dana Powers | 2014-12-15 | 1 | -44/+67 |
| | | | | | | | | list; add more type checks to set_topic_and_partitions | ||||
| * | Add set_topic_partitions method to configure topics/partitions to consume | Dana Powers | 2014-12-15 | 1 | -8/+59 |
| | | |||||
| * | Use client.get_partition_ids_for_topic | Dana Powers | 2014-12-15 | 1 | -4/+4 |
| | | |||||
| * | Use configure() to check and set configuration keys | Dana Powers | 2014-12-15 | 2 | -59/+71 |
| | | |||||
| * | add private methods _set_consumer_timeout_start() and _check_consumer_timeout() | Dana Powers | 2014-12-15 | 1 | -8/+13 |
| | | |||||
| * | Handle FailedPayloadsError on client.send_fetch_request; permit offsets(); ↵ | Dana Powers | 2014-12-15 | 1 | -16/+35 |
| | | | | | | | | update docstring | ||||
| * | A simpler kafka consumer: | Dana Powers | 2014-12-15 | 2 | -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 KeyedProducer | Jordan Shaw | 2014-12-15 | 1 | -0/+4 |
|/ | | | | Signed-off-by: Jordan Shaw <jordan@pubnub.com> | ||||
* | fix pending method | Nickolai Novik | 2014-12-15 | 1 | -1/+1 |
| | |||||
* | Added raise of TypeError for non bytes key | Lou Marvin Caraig | 2014-11-26 | 1 | -1/+6 |
| | |||||
* | Key is passed when creating messages for both async=False and async=True | Lou Marvin Caraig | 2014-11-26 | 2 | -6/+7 |
| | |||||
* | Added private method _send_messages that can accept kwargs | Lou Marvin Caraig | 2014-11-26 | 1 | -0/+2 |
| |