summaryrefslogtreecommitdiff
path: root/kafka/protocol/admin.py
diff options
context:
space:
mode:
Diffstat (limited to 'kafka/protocol/admin.py')
-rw-r--r--kafka/protocol/admin.py20
1 files changed, 20 insertions, 0 deletions
diff --git a/kafka/protocol/admin.py b/kafka/protocol/admin.py
index b2694dc..af88ea4 100644
--- a/kafka/protocol/admin.py
+++ b/kafka/protocol/admin.py
@@ -477,6 +477,13 @@ class DescribeAclsResponse_v1(Response):
('permission_type', Int8)))))
)
+
+class DescribeAclsResponse_v2(Response):
+ API_KEY = 29
+ API_VERSION = 2
+ SCHEMA = DescribeAclsResponse_v1.SCHEMA
+
+
class DescribeAclsRequest_v0(Request):
API_KEY = 29
API_VERSION = 0
@@ -490,6 +497,7 @@ class DescribeAclsRequest_v0(Request):
('permission_type', Int8)
)
+
class DescribeAclsRequest_v1(Request):
API_KEY = 29
API_VERSION = 1
@@ -504,6 +512,17 @@ class DescribeAclsRequest_v1(Request):
('permission_type', Int8)
)
+
+class DescribeAclsRequest_v2(Request):
+ """
+ Enable flexible version
+ """
+ API_KEY = 29
+ API_VERSION = 2
+ RESPONSE_TYPE = DescribeAclsResponse_v2
+ SCHEMA = DescribeAclsRequest_v1.SCHEMA
+
+
DescribeAclsRequest = [DescribeAclsRequest_v0, DescribeAclsRequest_v1]
DescribeAclsResponse = [DescribeAclsResponse_v0, DescribeAclsResponse_v1]
@@ -862,3 +881,4 @@ CreatePartitionsRequest = [
CreatePartitionsResponse = [
CreatePartitionsResponse_v0, CreatePartitionsResponse_v1,
]
+