diff options
| -rw-r--r-- | test/test_consumer_integration.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/test/test_consumer_integration.py b/test/test_consumer_integration.py index da2faf6..a6589b3 100644 --- a/test/test_consumer_integration.py +++ b/test/test_consumer_integration.py @@ -220,7 +220,7 @@ class TestConsumerIntegration(KafkaIntegrationTestCase): # Start a consumer consumer1 = self.consumer( - auto_commit_every_t = 600, + auto_commit_every_t = None, auto_commit_every_n = 20, ) @@ -230,7 +230,7 @@ class TestConsumerIntegration(KafkaIntegrationTestCase): # The total offset across both partitions should be at 180 consumer2 = self.consumer( - auto_commit_every_t = 600, + auto_commit_every_t = None, auto_commit_every_n = 20, ) |