diff options
| author | Dana Powers <dana.powers@gmail.com> | 2014-05-12 09:26:50 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2014-05-12 09:26:50 -0700 |
| commit | b13fa3f4a284a6ed4d9fd5fc6abbc627cdfe02e2 (patch) | |
| tree | 78550f9be70e83941bab6740f67c469c734dc3da | |
| parent | fddc152590f154bac2048e260a300826f8ed6f27 (diff) | |
| parent | 2e9a247b337100df0c6f5abfbd6650c6b219eae9 (diff) | |
| download | kafka-python-b13fa3f4a284a6ed4d9fd5fc6abbc627cdfe02e2.tar.gz | |
Merge pull request #169 from snaury/patch-1
Support IPv6 hosts and networks
| -rw-r--r-- | kafka/conn.py | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index 5dc3d5a..b5dafd8 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -149,7 +149,5 @@ class KafkaConnection(local): Re-initialize the socket connection """ self.close() - self._sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) - self._sock.settimeout(self.timeout) - self._sock.connect((self.host, self.port)) + self._sock = socket.create_connection((self.host, self.port), self.timeout) self._dirty = False |