Use 2-second KafkaClient timeout in failover tests

2016-01-03 16:25:12 -08:00
parent 50f6a25ceb
commit fa7ecdaf3f
1 changed files with 1 additions and 1 deletions
--- a/test/test_failover_integration.py
+++ b/test/test_failover_integration.py
@@ -34,7 +34,7 @@ class TestFailover(KafkaIntegrationTestCase):
        self.brokers = [KafkaFixture.instance(i, *kk_args) for i in range(replicas)]

        hosts = ['%s:%d' % (b.host, b.port) for b in self.brokers]
-        self.client = KafkaClient(hosts)
+        self.client = KafkaClient(hosts, timeout=2)
        super(TestFailover, self).setUp()

    def tearDown(self):