diff options
| author | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-04-21 13:37:16 +0300 |
|---|---|---|
| committer | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-06-03 11:22:47 +0300 |
| commit | 0e0f794802076db34e8e4dc597c38237e88f4b34 (patch) | |
| tree | 8fef0d8e9f4e3f56c622720163bbb44072b19fa0 | |
| parent | 09c1c8b117a3c8217ca36c27eafb22999c20ef93 (diff) | |
| download | kafka-python-0e0f794802076db34e8e4dc597c38237e88f4b34.tar.gz | |
Arg fixes for base/keyed producers
| -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: |