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 /test/test_producer_integration.py | |
| parent | 0f1579b047fc63c09596897cc1c83730bd0ddb94 (diff) | |
| download | kafka-python-aa217e05448b4eced017b5ecdcb020a4411f863f.tar.gz | |
Deprecate async producer batch_send kwarg -- use 'async' instead
Diffstat (limited to 'test/test_producer_integration.py')
| -rw-r--r-- | test/test_producer_integration.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/test/test_producer_integration.py b/test/test_producer_integration.py index 099b975..3c414e1 100644 --- a/test/test_producer_integration.py +++ b/test/test_producer_integration.py @@ -221,7 +221,7 @@ class TestKafkaProducerIntegration(KafkaIntegrationTestCase): batch_interval = 5 producer = SimpleProducer( self.client, - batch_send=True, + async=True, batch_send_every_n=batch_messages, batch_send_every_t=batch_interval, random_start=False) @@ -287,7 +287,7 @@ class TestKafkaProducerIntegration(KafkaIntegrationTestCase): batch_interval = 5 producer = SimpleProducer( self.client, - batch_send=True, + async=True, batch_send_every_n=100, batch_send_every_t=batch_interval, random_start=False) |