diff options
author | Ben Weir <bweir@linkedin.com> | 2018-12-06 11:58:48 -0800 |
---|---|---|
committer | Jeff Widman <jeff@jeffwidman.com> | 2019-01-03 13:54:59 -0800 |
commit | 70ea4c1e94a0ace46d3418fb0ee503bbf8a5b91b (patch) | |
tree | 05bd28b02327c04bb6aa6871866a33d21a0d473e | |
parent | 2e0ada055886ad01cc193b1007d3f79717b5c9df (diff) | |
download | kafka-python-70ea4c1e94a0ace46d3418fb0ee503bbf8a5b91b.tar.gz |
Fix SSL connection testing in Python 3.7
-rw-r--r-- | kafka/conn.py | 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: |