Skip to content

Commit d529423

Browse files
committed
fixup oauth receive
1 parent 331774f commit d529423

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

kafka/sasl/oauth.py

+2-3
Original file line numberDiff line numberDiff line change
@@ -18,9 +18,8 @@ def auth_bytes(self):
1818
return "n,,\x01auth=Bearer {}{}\x01\x01".format(token, extensions).encode('utf-8')
1919

2020
def receive(self, auth_bytes):
21-
if auth_bytes != b'':
22-
self._is_authenticated = False
23-
self._is_done = True
21+
self._is_done = True
22+
self._is_authenticated = auth_bytes == b''
2423

2524
def is_done(self):
2625
return self._is_done

0 commit comments

Comments
 (0)