Fix more gssapi errors (dpkp#1280)

dpkp · web-flow · commit 4213d53d4ccf · 2017-10-24T15:16:13.000-07:00
diff --git 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:
