From de5dd9f9208656a5291a9fdb73e93f3dbc75e6fc Mon Sep 17 00:00:00 2001 From: everpcpc Date: Thu, 28 Dec 2017 18:31:05 +0800 Subject: [PATCH] Fix typo in _try_authenticate_plain --- kafka/conn.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/conn.py b/kafka/conn.py index 246cab8d6..23edf227b 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -506,7 +506,7 @@ def _try_authenticate_plain(self, future): # 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)