Skip to content

Commit 70ea4c1

Browse files
Ben Weirjeffwidman
Ben Weir
authored andcommitted
Fix SSL connection testing in Python 3.7
1 parent 2e0ada0 commit 70ea4c1

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

kafka/conn.py

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -357,6 +357,13 @@ def connect(self):
357357
ret = self._sock.connect_ex(self._sock_addr)
358358
except socket.error as err:
359359
ret = err.errno
360+
except ValueError as err:
361+
# Python 3.7 and higher raises ValueError if a socket
362+
# is already connected
363+
if sys.version_info >= (3, 7):
364+
ret = None
365+
else:
366+
raise
360367

361368
# Connection succeeded
362369
if not ret or ret == errno.EISCONN:

0 commit comments

Comments
 (0)