Speedup some failover tests w/ shorter SimpleClient timeout

2016-04-07 21:31:57 -07:00
parent af36c6ddd0
commit 2037d5f735
1 changed files with 1 additions and 1 deletions
--- a/test/test_failover_integration.py
+++ b/test/test_failover_integration.py
@@ -214,7 +214,7 @@ class TestFailover(KafkaIntegrationTestCase):
        hosts = ','.join(['%s:%d' % (broker.host, broker.port)
                          for broker in self.brokers])

-        client = SimpleClient(hosts)
+        client = SimpleClient(hosts, timeout=2)
        consumer = SimpleConsumer(client, None, topic,
                                  partitions=partitions,
                                  auto_commit=False,