diff options
| author | maciejkula <noocrat@gmail.com> | 2014-04-16 17:05:45 +0100 |
|---|---|---|
| committer | maciejkula <noocrat@gmail.com> | 2014-04-16 17:05:45 +0100 |
| commit | ef4648a0840bf8a212de5c7129d38e34cb335acb (patch) | |
| tree | dd9a0a737a06a335c8e90a963ff9c4595df258aa /kafka/client.py | |
| parent | 13d0d445da2060b1b94c742e9d69cb1db22fc775 (diff) | |
| download | kafka-python-ef4648a0840bf8a212de5c7129d38e34cb335acb.tar.gz | |
Fix lack of timeout support in KafkaClient and KafkaConnection
Diffstat (limited to 'kafka/client.py')
| -rw-r--r-- | kafka/client.py | 2 |
1 files changed, 1 insertions, 1 deletions
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] |