diff options
Diffstat (limited to 'kafka/protocol/admin.py')
-rw-r--r-- | kafka/protocol/admin.py | 24 |
1 files changed, 18 insertions, 6 deletions
diff --git a/kafka/protocol/admin.py b/kafka/protocol/admin.py index 56dd042..8c74613 100644 --- a/kafka/protocol/admin.py +++ b/kafka/protocol/admin.py @@ -2,7 +2,9 @@ from .struct import Struct from .types import Array, Bytes, Int16, Schema, String -class ListGroupsResponse(Struct): +class ListGroupsResponse_v0(Struct): + API_KEY = 16 + API_VERSION = 0 SCHEMA = Schema( ('error_code', Int16), ('groups', Array( @@ -11,14 +13,20 @@ class ListGroupsResponse(Struct): ) -class ListGroupsRequest(Struct): +class ListGroupsRequest_v0(Struct): API_KEY = 16 API_VERSION = 0 - RESPONSE_TYPE = ListGroupsResponse + RESPONSE_TYPE = ListGroupsResponse_v0 SCHEMA = Schema() -class DescribeGroupsResponse(Struct): +ListGroupsRequest = [ListGroupsRequest_v0] +ListGroupsResponse = [ListGroupsResponse_v0] + + +class DescribeGroupsResponse_v0(Struct): + API_KEY = 15 + API_VERSION = 0 SCHEMA = Schema( ('groups', Array( ('error_code', Int16), @@ -35,10 +43,14 @@ class DescribeGroupsResponse(Struct): ) -class DescribeGroupsRequest(Struct): +class DescribeGroupsRequest_v0(Struct): API_KEY = 15 API_VERSION = 0 - RESPONSE_TYPE = DescribeGroupsResponse + RESPONSE_TYPE = DescribeGroupsResponse_v0 SCHEMA = Schema( ('groups', Array(String('utf-8'))) ) + + +DescribeGroupsRequest = [DescribeGroupsRequest_v0] +DescribeGroupsResponse = [DescribeGroupsResponse_v0] |