From 70ea4c1e94a0ace46d3418fb0ee503bbf8a5b91b Mon Sep 17 00:00:00 2001 From: Ben Weir Date: Thu, 6 Dec 2018 11:58:48 -0800 Subject: Fix SSL connection testing in Python 3.7 --- kafka/conn.py | 7 +++++++ 1 file changed, 7 insertions(+) (limited to 'kafka/conn.py') 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: -- cgit v1.2.1