diff options
| author | Dana Powers <dana.powers@gmail.com> | 2019-03-21 21:08:01 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2019-03-21 21:08:01 -0700 |
| commit | 9af1a88fdc97b1a6db41fb7fcc074f5c73cfd7ae (patch) | |
| tree | ec8cd5aff5676289e5369a3882826af435baa88d /kafka/conn.py | |
| parent | f2f2bfe44d51b3474f955c16c30ab132f14ba551 (diff) | |
| download | kafka-python-old_ssl_exception.tar.gz | |
Improve SSLWantReadError handling when ssl not availableold_ssl_exception
Diffstat (limited to 'kafka/conn.py')
| -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: |