We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 223c320 commit 539c33eCopy full SHA for 539c33e
kafka/sasl/gssapi.py
@@ -68,10 +68,10 @@ def receive(self, auth_bytes):
68
# simply set QoP to 'auth' only (first octet). We reuse the max message size proposed
69
# by the server
70
client_flags = self.SASL_QOP_AUTH
71
- server_flags = msg[0]
+ server_flags = struct.Struct('>b').unpack(msg[0:1])[0]
72
message_parts = [
73
struct.Struct('>b').pack(client_flags & server_flags),
74
- msg[1:],
+ msg[1:], # always agree to max message size from server
75
self.auth_id.encode('utf-8'),
76
]
77
# add authorization identity to the response, and GSS-wrap
0 commit comments