diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-08-03 11:46:56 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-08-03 11:46:56 -0700 |
| commit | 709ee3b59aff8ab205f0e09c33f4ec8391664228 (patch) | |
| tree | ca5a3e79e002bdb956e4faf73aeec6874ee8d9de /kafka/protocol/admin.py | |
| parent | c693709aaf9e292c8614b9ab345d3322d4f71caa (diff) | |
| parent | 787e8b2ba033cf3d961ca1f5ee345c279222ca8b (diff) | |
| download | kafka-python-709ee3b59aff8ab205f0e09c33f4ec8391664228.tar.gz | |
Support for PLAIN sasl authentication (PR #779)
Merge squashed branch 'larsjsol-sasl_plain'
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] |