From 0d48bd10fa2236ada4daaa0dd781c623a0433786 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Tue, 24 Oct 2017 11:18:03 -0700 Subject: [PATCH] Fix more gssapi errors --- kafka/conn.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/kafka/conn.py b/kafka/conn.py index da08eac76..c1c4fbbee 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -561,6 +561,9 @@ def _try_authenticate_gssapi(self, future): # calculate an output token from kafka token (or None if first iteration) output_token = client_ctx.step(received_token) + if output_token is None: + continue + # pass output token to kafka try: msg = output_token @@ -572,7 +575,7 @@ def _try_authenticate_gssapi(self, future): # The gssapi will be able to identify the needed next step. # The connection is closed on failure. header = self._recv_bytes_blocking(4) - token_size = struct.unpack('>i', header) + (token_size,) = struct.unpack('>i', header) received_token = self._recv_bytes_blocking(token_size) except ConnectionError as e: