diff options
| -rw-r--r-- | kafka/producer/base.py | 3 | ||||
| -rw-r--r-- | kafka/producer/keyed.py | 3 |
2 files changed, 2 insertions, 4 deletions
diff --git a/kafka/producer/base.py b/kafka/producer/base.py index ebeb82d..1d5e045 100644 --- a/kafka/producer/base.py +++ b/kafka/producer/base.py @@ -224,8 +224,7 @@ class Producer(object): batch_send_every_n, self.req_acks, self.ack_timeout, - batch_retry_backoff_ms, - batch_retries_limit, + batch_retry_options, self.thread_stop_event)) # Thread will die if main thread exits diff --git a/kafka/producer/keyed.py b/kafka/producer/keyed.py index d11db52..7bcc629 100644 --- a/kafka/producer/keyed.py +++ b/kafka/producer/keyed.py @@ -48,8 +48,7 @@ class KeyedProducer(Producer): 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, key): if topic not in self.partitioners: |