diff options
| author | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-04-21 13:30:46 +0300 |
|---|---|---|
| committer | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-06-03 11:22:47 +0300 |
| commit | 09c1c8b117a3c8217ca36c27eafb22999c20ef93 (patch) | |
| tree | 343f4dc19b5a42f992d3269cfd072f34b8b91788 /kafka/common.py | |
| parent | 5e8dc6dcf55890a4e3a214a943ecc655faed3ecc (diff) | |
| download | kafka-python-09c1c8b117a3c8217ca36c27eafb22999c20ef93.tar.gz | |
Improved retry logic
Diffstat (limited to 'kafka/common.py')
| -rw-r--r-- | kafka/common.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/kafka/common.py b/kafka/common.py index 5c2b788..cbb4013 100644 --- a/kafka/common.py +++ b/kafka/common.py @@ -78,6 +78,9 @@ TopicAndPartition = namedtuple("TopicAndPartition", KafkaMessage = namedtuple("KafkaMessage", ["topic", "partition", "offset", "key", "value"]) +RetryOptions = namedtuple("RetryOptions", + ["limit", "backoff_ms", "retry_on_timeouts"]) + ################# # Exceptions # |