diff options
| author | Stephen SORRIAUX <stephen.sorriaux@gmail.com> | 2018-04-18 23:55:49 +0200 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2018-04-18 14:55:49 -0700 |
| commit | 59b0c6f714f83b5dae2df97f12645c39a6cdc179 (patch) | |
| tree | cc47ea14fc9601fb948fdac6294a281d90e03990 | |
| parent | 908ac8f8d253b20d70e36ce4bae1aefb51769221 (diff) | |
| download | kafka-python-59b0c6f714f83b5dae2df97f12645c39a6cdc179.tar.gz | |
Added AlterConfigs and DescribeConfigs apis (#1472)
| -rw-r--r-- | kafka/protocol/admin.py | 97 |
1 files changed, 96 insertions, 1 deletions
diff --git a/kafka/protocol/admin.py b/kafka/protocol/admin.py index de6b996..ed9026a 100644 --- a/kafka/protocol/admin.py +++ b/kafka/protocol/admin.py @@ -1,7 +1,7 @@ from __future__ import absolute_import from kafka.protocol.api import Request, Response -from kafka.protocol.types import Array, Boolean, Bytes, Int16, Int32, Schema, String +from kafka.protocol.types import Array, Boolean, Bytes, Int8, Int16, Int32, Schema, String class ApiVersionResponse_v0(Response): @@ -310,6 +310,101 @@ class SaslHandShakeRequest_v1(Request): SaslHandShakeRequest = [SaslHandShakeRequest_v0, SaslHandShakeRequest_v1] SaslHandShakeResponse = [SaslHandShakeResponse_v0, SaslHandShakeResponse_v1] +class AlterConfigsResponse_v0(Response): + API_KEY = 33 + API_VERSION = 0 + SCHEMA = Schema( + ('throttle_time_ms', Int32), + ('resources', Array( + ('error_code', Int16), + ('error_message', String('utf-8')), + ('resource_type', Int8), + ('resource_name', String('utf-8')))) + ) + +class AlterConfigsRequest_v0(Request): + API_KEY = 33 + API_VERSION = 0 + RESPONSE_TYPE = AlterConfigsResponse_v0 + SCHEMA = Schema( + ('resources', Array( + ('resource_type', Int8), + ('resource_name', String('utf-8')), + ('config_entries', Array( + ('config_name', String('utf-8')), + ('config_value', String('utf-8')))))), + ('validate_only', Boolean) + ) + +AlterConfigsRequest = [AlterConfigsRequest_v0] +AlterConfigsResponse = [AlterConfigsResponse_v0] + + +class DescribeConfigsResponse_v0(Response): + API_KEY = 32 + API_VERSION = 0 + SCHEMA = Schema( + ('throttle_time_ms', Int32), + ('resources', Array( + ('error_code', Int16), + ('error_message', String('utf-8')), + ('resource_type', Int8), + ('resource_name', String('utf-8')), + ('config_entries', Array( + ('config_names', String('utf-8')), + ('config_value', String('utf-8')), + ('read_only', Boolean), + ('is_default', Boolean), + ('is_sensitive', Boolean))))) + ) + +class DescribeConfigsResponse_v1(Response): + API_KEY = 32 + API_VERSION = 1 + SCHEMA = Schema( + ('throttle_time_ms', Int32), + ('resources', Array( + ('error_code', Int16), + ('error_message', String('utf-8')), + ('resource_type', Int8), + ('resource_name', String('utf-8')), + ('config_entries', Array( + ('config_names', String('utf-8')), + ('config_value', String('utf-8')), + ('read_only', Boolean), + ('is_default', Boolean), + ('is_sensitive', Boolean), + ('config_synonyms', Array( + ('config_name', String('utf-8')), + ('config_value', String('utf-8')), + ('config_source', Int8))))))) + ) + +class DescribeConfigsRequest_v0(Request): + API_KEY = 32 + API_VERSION = 0 + RESPONSE_TYPE = DescribeConfigsResponse_v0 + SCHEMA = Schema( + ('resources', Array( + ('resource_type', Int8), + ('resource_name', String('utf-8')), + ('config_names', Array(String('utf-8'))))) + ) + +class DescribeConfigsRequest_v1(Request): + API_KEY = 32 + API_VERSION = 1 + RESPONSE_TYPE = DescribeConfigsResponse_v1 + SCHEMA = Schema( + ('resources', Array( + ('resource_type', Int8), + ('resource_name', String('utf-8')), + ('config_names', Array(String('utf-8'))))), + ('include_synonyms', Boolean) + ) + +DescribeConfigsRequest = [DescribeConfigsRequest_v0, DescribeConfigsRequest_v1] +DescribeConfigsResponse = [DescribeConfigsResponse_v0, DescribeConfigsResponse_v1] class SaslAuthenticateResponse_v0(Request): API_KEY = 36 |