From 1904b536b0a6fb83e006f3a61b2aa360797cf838 Mon Sep 17 00:00:00 2001
From: Daniel Johansson <danjo133@gmail.com>
Date: Wed, 13 Mar 2019 06:03:11 +0100
Subject: Catch thrown OSError by python 3.7 when creating a connection (#1694)

---
 kafka/conn.py | 3 +++
 1 file changed, 3 insertions(+)

(limited to 'kafka/conn.py')

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'))
-- 
cgit v1.2.1