diff options
| author | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-04-22 12:14:11 +0300 |
|---|---|---|
| committer | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-06-03 11:22:48 +0300 |
| commit | 5119bb605acc4b24e091778656b229a36f9cac11 (patch) | |
| tree | 82c2aa8108c36570c3e8e8c9fd022a5ab18e86f3 /kafka/common.py | |
| parent | 7da48f62975385e15e4115df70986688837058b8 (diff) | |
| download | kafka-python-5119bb605acc4b24e091778656b229a36f9cac11.tar.gz | |
Fix names for async retries opts, add timeout for put
Diffstat (limited to 'kafka/common.py')
| -rw-r--r-- | kafka/common.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/common.py b/kafka/common.py index e327d02..87c29f0 100644 --- a/kafka/common.py +++ b/kafka/common.py @@ -78,12 +78,12 @@ TopicAndPartition = namedtuple("TopicAndPartition", KafkaMessage = namedtuple("KafkaMessage", ["topic", "partition", "offset", "key", "value"]) +# Define retry policy for async producer +# Limit corner values: None - infinite retries, 0 - no retries RetryOptions = namedtuple("RetryOptions", ["limit", "backoff_ms", "retry_on_timeouts"]) - - ################# # Exceptions # ################# |