Skip to content

Commit 2f6d462

Browse files
author
Tyler Lubeck
committed
Add support for ApiVersions API v2
1 parent fc417fc commit 2f6d462

File tree

1 file changed

+19
-2
lines changed

1 file changed

+19
-2
lines changed

kafka/protocol/admin.py

Lines changed: 19 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,12 @@ class ApiVersionResponse_v1(Response):
2929
)
3030

3131

32+
class ApiVersionResponse_v2(Response):
33+
API_KEY = 18
34+
API_VERSION = 2
35+
SCHEMA = ApiVersionResponse_v1.SCHEMA
36+
37+
3238
class ApiVersionRequest_v0(Request):
3339
API_KEY = 18
3440
API_VERSION = 0
@@ -43,8 +49,19 @@ class ApiVersionRequest_v1(Request):
4349
SCHEMA = ApiVersionRequest_v0.SCHEMA
4450

4551

46-
ApiVersionRequest = [ApiVersionRequest_v0, ApiVersionRequest_v1]
47-
ApiVersionResponse = [ApiVersionResponse_v0, ApiVersionResponse_v1]
52+
class ApiVersionRequest_v2(Request):
53+
API_KEY = 18
54+
API_VERSION = 2
55+
RESPONSE_TYPE = ApiVersionResponse_v1
56+
SCHEMA = ApiVersionRequest_v0.SCHEMA
57+
58+
59+
ApiVersionRequest = [
60+
ApiVersionRequest_v0, ApiVersionRequest_v1, ApiVersionRequest_v2,
61+
]
62+
ApiVersionResponse = [
63+
ApiVersionResponse_v0, ApiVersionResponse_v1, ApiVersionResponse_v2,
64+
]
4865

4966

5067
class CreateTopicsResponse_v0(Response):

0 commit comments

Comments
 (0)