Improve SSLWantReadError handling when ssl not availableold_ssl_exception

1 files 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: