From b13a95c272cf0a09477d71b4b27fdfe9133835fa Mon Sep 17 00:00:00 2001 From: Ben Weir Date: Thu, 6 Dec 2018 11:58:48 -0800 Subject: [PATCH] Fix SSL connection testing in Python 3.7 --- kafka/conn.py | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/kafka/conn.py b/kafka/conn.py index 471bae7ed..4d56964e3 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -357,6 +357,13 @@ def connect(self): 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: