From ef4648a0840bf8a212de5c7129d38e34cb335acb Mon Sep 17 00:00:00 2001 From: maciejkula Date: Wed, 16 Apr 2014 17:05:45 +0100 Subject: Fix lack of timeout support in KafkaClient and KafkaConnection --- kafka/client.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'kafka/client.py') diff --git a/kafka/client.py b/kafka/client.py index 39c89ba..5dee7b7 100644 --- a/kafka/client.py +++ b/kafka/client.py @@ -48,7 +48,7 @@ class KafkaClient(object): host_key = (host, port) if host_key not in self.conns: - self.conns[host_key] = KafkaConnection(host, port) + self.conns[host_key] = KafkaConnection(host, port, timeout=self.timeout) return self.conns[host_key] -- cgit v1.2.1