summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMark Roberts <wizzat@gmail.com>2014-05-06 22:56:24 -0700
committerMark Roberts <wizzat@gmail.com>2014-05-06 22:56:24 -0700
commitb81bf5f69e24b0d0106693b6e47906669873ec18 (patch)
treec74db904c37ba1e70dab6dd2c78f4c1a4abd173f
parentb053da2203f2597801609824b510cfcc2e821d63 (diff)
downloadkafka-python-b81bf5f69e24b0d0106693b6e47906669873ec18.tar.gz
Make test suite more robust against very slow test suites
-rw-r--r--test/test_consumer_integration.py4
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,
)