From 2e9a247b337100df0c6f5abfbd6650c6b219eae9 Mon Sep 17 00:00:00 2001 From: Alexey Borzenkov Date: Fri, 9 May 2014 13:37:29 +0400 Subject: [PATCH] Support IPv6 hosts and networks --- kafka/conn.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/kafka/conn.py b/kafka/conn.py index 5dc3d5acb..b5dafd8fd 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -149,7 +149,5 @@ def reinit(self): 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