Skip to content

Commit 42681e6

Browse files
committed
Fix DescribeGroups v3
1 parent 47a2be9 commit 42681e6

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

kafka/protocol/admin.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -337,8 +337,8 @@ class DescribeGroupsResponse_v3(Response):
337337
('client_id', String('utf-8')),
338338
('client_host', String('utf-8')),
339339
('member_metadata', Bytes),
340-
('member_assignment', Bytes)))),
341-
('authorized_operations', Int32))
340+
('member_assignment', Bytes))),
341+
('authorized_operations', Int32)))
342342
)
343343

344344

@@ -368,7 +368,7 @@ class DescribeGroupsRequest_v2(Request):
368368
class DescribeGroupsRequest_v3(Request):
369369
API_KEY = 15
370370
API_VERSION = 3
371-
RESPONSE_TYPE = DescribeGroupsResponse_v2
371+
RESPONSE_TYPE = DescribeGroupsResponse_v3
372372
SCHEMA = Schema(
373373
('groups', Array(String('utf-8'))),
374374
('include_authorized_operations', Boolean)

0 commit comments

Comments
 (0)