diff options
| author | Dana Powers <dana.powers@gmail.com> | 2015-12-02 13:45:54 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2015-12-02 13:45:54 -0800 |
| commit | da217442c18090a6e8b615a3af17f0bdd93c14c8 (patch) | |
| tree | 13b830bd2088d6488fef7312b13e7728506e2372 /kafka/consumer/base.py | |
| parent | a0f103eb3f8ff19926dfd25a1d5c114237c0bdfa (diff) | |
| parent | 7e19de555007b1059af78097aa70c8810a473513 (diff) | |
| download | kafka-python-da217442c18090a6e8b615a3af17f0bdd93c14c8.tar.gz | |
Merge pull request #456 from barricadeio/mp-retry
Support retry semantics in MultiProcessConsumer
Diffstat (limited to 'kafka/consumer/base.py')
| -rw-r--r-- | kafka/consumer/base.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/kafka/consumer/base.py b/kafka/consumer/base.py index 25c01a1..c9f6e48 100644 --- a/kafka/consumer/base.py +++ b/kafka/consumer/base.py @@ -29,6 +29,7 @@ ITER_TIMEOUT_SECONDS = 60 NO_MESSAGES_WAIT_TIME_SECONDS = 0.1 FULL_QUEUE_WAIT_TIME_SECONDS = 0.1 +MAX_BACKOFF_SECONDS = 60 class Consumer(object): """ |