We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c9596ff commit c28567fCopy full SHA for c28567f
1 file changed
kafka/admin/client.py
@@ -651,12 +651,11 @@ def describe_acls(self, acl_filter):
651
request = DescribeAclsRequest[version](
652
resource_type_filter=acl_filter.resource_pattern.resource_type,
653
resource_name_filter=acl_filter.resource_pattern.resource_name,
654
- resource_pattern_type_filter=acl_filter.resource_pattern.pattern_type,
+ pattern_type_filter=acl_filter.resource_pattern.pattern_type,
655
principal_filter=acl_filter.principal,
656
- host=acl_filter.host,
+ host_filter=acl_filter.host,
657
operation=acl_filter.operation,
658
permission_type=acl_filter.permission_type
659
-
660
)
661
response = self.send_request(request) # pylint: disable=E0606
662
error_type = Errors.for_code(response.error_code)
0 commit comments