diff options
author | Mark Roberts <wizzat@gmail.com> | 2014-05-06 22:56:24 -0700 |
---|---|---|
committer | Mark Roberts <wizzat@gmail.com> | 2014-05-06 22:56:24 -0700 |
commit | b81bf5f69e24b0d0106693b6e47906669873ec18 (patch) | |
tree | c74db904c37ba1e70dab6dd2c78f4c1a4abd173f | |
parent | b053da2203f2597801609824b510cfcc2e821d63 (diff) | |
download | kafka-python-b81bf5f69e24b0d0106693b6e47906669873ec18.tar.gz |
Make test suite more robust against very slow test suites
-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, ) |