summaryrefslogtreecommitdiff
path: root/kafka/protocol/admin.py
diff options
context:
space:
mode:
Diffstat (limited to 'kafka/protocol/admin.py')
-rw-r--r--kafka/protocol/admin.py21
1 files changed, 21 insertions, 0 deletions
diff --git a/kafka/protocol/admin.py b/kafka/protocol/admin.py
index 12181d7..747684f 100644
--- a/kafka/protocol/admin.py
+++ b/kafka/protocol/admin.py
@@ -78,3 +78,24 @@ class DescribeGroupsRequest_v0(Struct):
DescribeGroupsRequest = [DescribeGroupsRequest_v0]
DescribeGroupsResponse = [DescribeGroupsResponse_v0]
+
+
+class SaslHandShakeResponse_v0(Struct):
+ API_KEY = 17
+ API_VERSION = 0
+ SCHEMA = Schema(
+ ('error_code', Int16),
+ ('enabled_mechanisms', Array(String('utf-8')))
+ )
+
+
+class SaslHandShakeRequest_v0(Struct):
+ API_KEY = 17
+ API_VERSION = 0
+ RESPONSE_TYPE = SaslHandShakeResponse_v0
+ SCHEMA = Schema(
+ ('mechanism', String('utf-8'))
+ )
+
+SaslHandShakeRequest = [SaslHandShakeRequest_v0]
+SaslHandShakeResponse = [SaslHandShakeResponse_v0]