diff options
| author | Daniel Johansson <danjo133@gmail.com> | 2019-03-13 06:03:11 +0100 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2019-03-12 22:03:11 -0700 |
| commit | 1904b536b0a6fb83e006f3a61b2aa360797cf838 (patch) | |
| tree | 66fd9a3c3c7505b0b3158d4ab6d4f5b7241a3457 | |
| parent | c0add71e8d656691c0dd2dcb1936953f4483285b (diff) | |
| download | kafka-python-1904b536b0a6fb83e006f3a61b2aa360797cf838.tar.gz | |
Catch thrown OSError by python 3.7 when creating a connection (#1694)
| -rw-r--r-- | kafka/conn.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index c273765..4f324c8 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -483,6 +483,9 @@ class BrokerConnection(object): # old ssl in python2.6 will swallow all SSLErrors here... except (SSLWantReadError, SSLWantWriteError): pass + # python 3.7 throws OSError + except OSError: + pass except (SSLZeroReturnError, ConnectionError, SSLEOFError): log.warning('SSL connection closed by server during handshake.') self.close(Errors.KafkaConnectionError('SSL connection closed by server during handshake')) |