We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c0add71 commit 1904b53Copy full SHA for 1904b53
kafka/conn.py
@@ -483,6 +483,9 @@ def _try_handshake(self):
483
# old ssl in python2.6 will swallow all SSLErrors here...
484
except (SSLWantReadError, SSLWantWriteError):
485
pass
486
+ # python 3.7 throws OSError
487
+ except OSError:
488
+ pass
489
except (SSLZeroReturnError, ConnectionError, SSLEOFError):
490
log.warning('SSL connection closed by server during handshake.')
491
self.close(Errors.KafkaConnectionError('SSL connection closed by server during handshake'))
0 commit comments