diff options
| author | everpcpc <git@everpcpc.com> | 2017-12-29 00:59:58 +0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2017-12-28 08:59:58 -0800 |
| commit | 794b695e7ceff25834616bb54e32160104040df4 (patch) | |
| tree | c4e5cda4878bbc6727f55dc0825f4d9244b3f65a | |
| parent | 4cfeaca5c867e15213420caad400f5f1863f64e3 (diff) | |
| download | kafka-python-794b695e7ceff25834616bb54e32160104040df4.tar.gz | |
Fix typo in _try_authenticate_plain (#1333)
| -rw-r--r-- | kafka/conn.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index 246cab8..23edf22 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -506,7 +506,7 @@ class BrokerConnection(object): # The server will send a zero sized message (that is Int32(0)) on success. # The connection is closed on failure - self._recv_bytes_blocking(4) + data = self._recv_bytes_blocking(4) except ConnectionError as e: log.exception("%s: Error receiving reply from server", self) |