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/producer/simple.py | |
| parent | 5e8dc6dcf55890a4e3a214a943ecc655faed3ecc (diff) | |
| download | kafka-python-09c1c8b117a3c8217ca36c27eafb22999c20ef93.tar.gz | |
Improved retry logic
Diffstat (limited to 'kafka/producer/simple.py')
| -rw-r--r-- | kafka/producer/simple.py | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/kafka/producer/simple.py b/kafka/producer/simple.py index 7391be0..b869683 100644 --- a/kafka/producer/simple.py +++ b/kafka/producer/simple.py @@ -10,8 +10,7 @@ from six.moves import xrange from .base import ( Producer, BATCH_SEND_DEFAULT_INTERVAL, - BATCH_SEND_MSG_COUNT, - BATCH_RETRY_BACKOFF_MS, BATCH_RETRIES_LIMIT + BATCH_SEND_MSG_COUNT, BATCH_RETRY_OPTIONS ) log = logging.getLogger("kafka") @@ -47,16 +46,14 @@ class SimpleProducer(Producer): batch_send_every_n=BATCH_SEND_MSG_COUNT, batch_send_every_t=BATCH_SEND_DEFAULT_INTERVAL, random_start=True, - batch_retry_backoff_ms=BATCH_RETRY_BACKOFF_MS, - batch_retries_limit=BATCH_RETRIES_LIMIT): + batch_retry_options=BATCH_RETRY_OPTIONS): self.partition_cycles = {} self.random_start = random_start super(SimpleProducer, self).__init__(client, async, req_acks, ack_timeout, codec, batch_send, batch_send_every_n, batch_send_every_t, - batch_retry_backoff_ms, - batch_retries_limit) + batch_retry_options) def _next_partition(self, topic): if topic not in self.partition_cycles: |