Support IPv6 hosts and networks

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