From 9af1a88fdc97b1a6db41fb7fcc074f5c73cfd7ae Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Thu, 21 Mar 2019 21:08:01 -0700 Subject: Improve SSLWantReadError handling when ssl not available --- kafka/conn.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/kafka/conn.py b/kafka/conn.py index cdc0a86..d2ee9d9 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -861,9 +861,6 @@ class BrokerConnection(object): return [] else: recvd.append(data) - - except SSLWantReadError: - break except ConnectionError as e: if six.PY2 and e.errno == errno.EWOULDBLOCK: break @@ -875,6 +872,10 @@ class BrokerConnection(object): if six.PY3: break raise + except SSLWantReadError: + if ssl_available: + break + raise recvd_data = b''.join(recvd) if self._sensors: -- cgit v1.2.1