diff options
| author | Lars Jørgen Solberg <larsjs@met.no> | 2016-07-25 08:40:38 +0000 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-08-03 11:44:33 -0700 |
| commit | 6b801a8d2e3ec387c681100df02de49b322ffedd (patch) | |
| tree | c01b1302a7100118361d6663159f01a46bde6824 /kafka/protocol/admin.py | |
| parent | c693709aaf9e292c8614b9ab345d3322d4f71caa (diff) | |
| download | kafka-python-6b801a8d2e3ec387c681100df02de49b322ffedd.tar.gz | |
implement sasl PLAIN mechanism
Diffstat (limited to 'kafka/protocol/admin.py')
| -rw-r--r-- | kafka/protocol/admin.py | 21 |
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] |