diff options
Diffstat (limited to 'test')
| -rw-r--r-- | test/test_producer_integration.py | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/test/test_producer_integration.py b/test/test_producer_integration.py index 176c99e..a304e83 100644 --- a/test/test_producer_integration.py +++ b/test/test_producer_integration.py @@ -398,14 +398,17 @@ class TestKafkaProducerIntegration(KafkaIntegrationTestCase): partition = self.client.get_partition_ids_for_topic(self.topic)[0] start_offset = self.current_offset(self.topic, partition) - producer = KeyedProducer(self.client, partitioner = RoundRobinPartitioner, async=True) + producer = KeyedProducer(self.client, + partitioner=RoundRobinPartitioner, + async=True, + batch_send_every_t=1) resp = producer.send_messages(self.topic, self.key("key1"), self.msg("one")) self.assertEqual(len(resp), 0) # wait for the server to report a new highwatermark while self.current_offset(self.topic, partition) == start_offset: - time.sleep(0.1) + time.sleep(0.1) self.assert_fetch_offset(partition, start_offset, [ self.msg("one") ]) |