From 6b801a8d2e3ec387c681100df02de49b322ffedd Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Lars=20J=C3=B8rgen=20Solberg?= <larsjs@met.no>
Date: Mon, 25 Jul 2016 08:40:38 +0000
Subject: implement sasl PLAIN mechanism

---
 kafka/protocol/admin.py | 21 +++++++++++++++++++++
 1 file changed, 21 insertions(+)

(limited to 'kafka/protocol/admin.py')

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]
-- 
cgit v1.2.1