Make test suite more robust against very slow test suites

2014-05-06 22:56:24 -07:00
parent b053da2203
commit b81bf5f69e
1 changed files with 2 additions and 2 deletions
--- 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,
        )