Skip to content

Commit 4b475a3

Browse files
authored
Admin Response tests and bitfield type patches (#2747)
1 parent 857d027 commit 4b475a3

3 files changed

Lines changed: 388 additions & 79 deletions

File tree

kafka/protocol/new/admin/cluster.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,11 @@
44

55

66
class DescribeClusterRequest(ApiMessage): pass
7-
class DescribeClusterResponse(ApiMessage): pass
7+
class DescribeClusterResponse(ApiMessage):
8+
@classmethod
9+
def json_patch(cls, json):
10+
json['fields'][7]['type'] = 'bitfield'
11+
return json
812

913
class DescribeConfigsRequest(ApiMessage): pass
1014
class DescribeConfigsResponse(ApiMessage): pass

kafka/protocol/new/admin/groups.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,13 @@
22

33

44
class DescribeGroupsRequest(ApiMessage): pass
5-
class DescribeGroupsResponse(ApiMessage): pass
5+
class DescribeGroupsResponse(ApiMessage):
6+
@classmethod
7+
def json_patch(cls, json):
8+
# group authorized_operations
9+
json['fields'][1]['fields'][7]['type'] = 'bitfield'
10+
return json
11+
612

713
class ListGroupsRequest(ApiMessage): pass
814
class ListGroupsResponse(ApiMessage): pass

0 commit comments

Comments
 (0)