Fix SSL connection testing in Python 3.7

1 files changed, 7 insertions, 0 deletions

diff --git a/kafka/conn.py b/kafka/conn.py
index 471bae7..4d56964 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -357,6 +357,13 @@ class BrokerConnection(object):
                 ret = self._sock.connect_ex(self._sock_addr)
             except socket.error as err:
                 ret = err.errno
+            except ValueError as err:
+                # Python 3.7 and higher raises ValueError if a socket
+                # is already connected
+                if sys.version_info >= (3, 7):
+                    ret = None
+                else:
+                    raise
 
             # Connection succeeded
             if not ret or ret == errno.EISCONN: