From 622b853f4c1ab7115602fd84930beaf44729687f Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Thu, 7 Apr 2016 21:31:57 -0700 Subject: Speedup some failover tests w/ shorter SimpleClient timeout --- test/test_failover_integration.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/test/test_failover_integration.py b/test/test_failover_integration.py index f03dfd9..9c2163c 100644 --- 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, -- cgit v1.2.1