diff options
| -rw-r--r-- | kafka/conn.py | 7 |
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: |