diff options
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 # ################# |