Skip to content

Commit 804faf4

Browse files
author
Swen Wenzel
committed
add DeleteGroups to protocol.admin
1 parent 4b76d41 commit 804faf4

File tree

1 file changed

+41
-0
lines changed

1 file changed

+41
-0
lines changed

kafka/protocol/admin.py

Lines changed: 41 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -882,3 +882,44 @@ class CreatePartitionsRequest_v1(Request):
882882
CreatePartitionsResponse_v0, CreatePartitionsResponse_v1,
883883
]
884884

885+
886+
class DeleteGroupsResponse_v0(Response):
887+
API_KEY = 42
888+
API_VERSION = 0
889+
SCHEMA = Schema(
890+
("throttle_time_ms", Int32),
891+
("results", Array(
892+
("group_id", String("utf-8")),
893+
("error_code", Int16)))
894+
)
895+
896+
897+
class DeleteGroupsResponse_v1(Response):
898+
API_KEY = 42
899+
API_VERSION = 1
900+
SCHEMA = DeleteGroupsResponse_v0.SCHEMA
901+
902+
903+
class DeleteGroupsRequest_v0(Request):
904+
API_KEY = 42
905+
API_VERSION = 0
906+
RESPONSE_TYPE = DeleteGroupsResponse_v0
907+
SCHEMA = Schema(
908+
("groups_names", Array(String("utf-8")))
909+
)
910+
911+
912+
class DeleteGroupsRequest_v1(Request):
913+
API_KEY = 42
914+
API_VERSION = 1
915+
RESPONSE_TYPE = DeleteGroupsResponse_v1
916+
SCHEMA = DeleteGroupsRequest_v0.SCHEMA
917+
918+
919+
DeleteGroupsRequest = [
920+
DeleteGroupsRequest_v0, DeleteGroupsRequest_v1
921+
]
922+
923+
DeleteGroupsResponse = [
924+
DeleteGroupsResponse_v0, DeleteGroupsResponse_v1
925+
]

0 commit comments

Comments
 (0)