diff options
Diffstat (limited to 'test/test_producer_integration.py')
| -rw-r--r-- | test/test_producer_integration.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/test/test_producer_integration.py b/test/test_producer_integration.py index 6cd3d13..2b81047 100644 --- a/test/test_producer_integration.py +++ b/test/test_producer_integration.py @@ -216,7 +216,7 @@ class TestKafkaProducerIntegration(KafkaIntegrationTestCase): partition = self.client.get_partition_ids_for_topic(self.topic)[0] start_offset = self.current_offset(self.topic, partition) - producer = SimpleProducer(self.client, async=True, random_start=False) + producer = SimpleProducer(self.client, async_send=True, random_start=False) resp = producer.send_messages(self.topic, self.msg("one")) self.assertEqual(len(resp), 0) @@ -235,7 +235,7 @@ class TestKafkaProducerIntegration(KafkaIntegrationTestCase): batch_interval = 5 producer = SimpleProducer( self.client, - async=True, + async_send=True, batch_send_every_n=batch_messages, batch_send_every_t=batch_interval, random_start=False) @@ -300,7 +300,7 @@ class TestKafkaProducerIntegration(KafkaIntegrationTestCase): batch_interval = 5 producer = SimpleProducer( self.client, - async=True, + async_send=True, batch_send_every_n=100, batch_send_every_t=batch_interval, random_start=False) @@ -432,7 +432,7 @@ class TestKafkaProducerIntegration(KafkaIntegrationTestCase): producer = KeyedProducer(self.client, partitioner=RoundRobinPartitioner, - async=True, + async_send=True, batch_send_every_t=1) resp = producer.send_messages(self.topic, self.key("key1"), self.msg("one")) |