diff options
Diffstat (limited to 'kafka/producer/keyed.py')
| -rw-r--r-- | kafka/producer/keyed.py | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/kafka/producer/keyed.py b/kafka/producer/keyed.py index aa569b3..d11db52 100644 --- a/kafka/producer/keyed.py +++ b/kafka/producer/keyed.py @@ -7,8 +7,7 @@ from kafka.util import kafka_bytestring 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") @@ -39,8 +38,7 @@ class KeyedProducer(Producer): batch_send=False, batch_send_every_n=BATCH_SEND_MSG_COUNT, batch_send_every_t=BATCH_SEND_DEFAULT_INTERVAL, - batch_retry_backoff_ms=BATCH_RETRY_BACKOFF_MS, - batch_retries_limit=BATCH_RETRIES_LIMIT): + batch_retry_options=BATCH_RETRY_OPTIONS): if not partitioner: partitioner = HashedPartitioner self.partitioner_class = partitioner |