File tree Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Original file line number Diff line number Diff line change @@ -561,6 +561,9 @@ def _try_authenticate_gssapi(self, future):
561
561
# calculate an output token from kafka token (or None if first iteration)
562
562
output_token = client_ctx .step (received_token )
563
563
564
+ if output_token is None :
565
+ continue
566
+
564
567
# pass output token to kafka
565
568
try :
566
569
msg = output_token
@@ -572,7 +575,7 @@ def _try_authenticate_gssapi(self, future):
572
575
# The gssapi will be able to identify the needed next step.
573
576
# The connection is closed on failure.
574
577
header = self ._recv_bytes_blocking (4 )
575
- token_size = struct .unpack ('>i' , header )
578
+ ( token_size ,) = struct .unpack ('>i' , header )
576
579
received_token = self ._recv_bytes_blocking (token_size )
577
580
578
581
except ConnectionError as e :
You can’t perform that action at this time.
0 commit comments