diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-06-05 14:12:14 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-06-06 19:27:56 -0700 |
| commit | aa217e05448b4eced017b5ecdcb020a4411f863f (patch) | |
| tree | 0d3a32aed0b2773643af5c7189c63b44a53dfd68 /kafka/producer/simple.py | |
| parent | 0f1579b047fc63c09596897cc1c83730bd0ddb94 (diff) | |
| download | kafka-python-aa217e05448b4eced017b5ecdcb020a4411f863f.tar.gz | |
Deprecate async producer batch_send kwarg -- use 'async' instead
Diffstat (limited to 'kafka/producer/simple.py')
| -rw-r--r-- | kafka/producer/simple.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/producer/simple.py b/kafka/producer/simple.py index 78cc21c..280a02e 100644 --- a/kafka/producer/simple.py +++ b/kafka/producer/simple.py @@ -54,8 +54,8 @@ class SimpleProducer(Producer): async_queue_put_timeout=ASYNC_QUEUE_PUT_TIMEOUT): self.partition_cycles = {} self.random_start = random_start - super(SimpleProducer, self).__init__(client, async, req_acks, - ack_timeout, codec, batch_send, + super(SimpleProducer, self).__init__(client, req_acks, ack_timeout, + codec, async, batch_send, batch_send_every_n, batch_send_every_t, async_retry_limit, |