diff options
| author | Dana Powers <dana.powers@gmail.com> | 2018-03-23 05:58:55 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-03-23 05:58:55 -0700 |
| commit | b62006aeb86258b4b1ef2735bebb1fe99459b82d (patch) | |
| tree | 9a5cab083163b8e5d952d1bb0f3bb7141ffb746a /test/test_producer_integration.py | |
| parent | 204388b0928c02a339eb84b376c74851eb074e69 (diff) | |
| download | kafka-python-b62006aeb86258b4b1ef2735bebb1fe99459b82d.tar.gz | |
Change SimpleProducer to use async_send (async is reserved in py37) (#1454)
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")) |