Support IPv6 hosts and networks

2014-05-09 13:37:29 +04:00
parent fddc152590
commit 2e9a247b33
1 changed files with 1 additions and 3 deletions
--- 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