root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: Replace ACL_AUTHORIZER attribute with ZK_ACL_AUTHORIZER (#12247) 

Replace ACL_AUTHORIZER attribute with ZK_ACL_AUTHORIZER in system tests. Required after the changes merged with https://github.com/apache/kafka/pull/12190.

Reviewers: David Jacot <djacot@confluent.io>
This commit is contained in:
Aneesh Garg 2022-06-03 21:20:49 +05:30 committed by GitHub
parent 7e71483aed
commit 47bb93cfd7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tests/kafkatest/tests/core/security_rolling_upgrade_test.py
View File

@ -71,7 +71,7 @@ class TestSecurityRollingUpgrade(ProduceConsumeValidateTest):
self.set_authorizer_and_bounce(client_protocol, broker_protocol) self.set_authorizer_and_bounce(client_protocol, broker_protocol)
def set_authorizer_and_bounce(self, client_protocol, broker_protocol): def set_authorizer_and_bounce(self, client_protocol, broker_protocol):
self.kafka.authorizer_class_name = KafkaService.ACL_AUTHORIZER self.kafka.authorizer_class_name = KafkaService.ZK_ACL_AUTHORIZER
# Force use of direct ZooKeeper access due to SecurityDisabledException: No Authorizer is configured on the broker. # Force use of direct ZooKeeper access due to SecurityDisabledException: No Authorizer is configured on the broker.
self.acls.set_acls(client_protocol, self.kafka, self.topic, self.group, force_use_zk_connection=True) self.acls.set_acls(client_protocol, self.kafka, self.topic, self.group, force_use_zk_connection=True)
self.acls.set_acls(broker_protocol, self.kafka, self.topic, self.group, force_use_zk_connection=True) self.acls.set_acls(broker_protocol, self.kafka, self.topic, self.group, force_use_zk_connection=True)

2
tests/kafkatest/tests/core/zookeeper_security_upgrade_test.py
View File

@ -95,7 +95,7 @@ class ZooKeeperSecurityUpgradeTest(ProduceConsumeValidateTest):
# set acls # set acls
if self.is_secure: if self.is_secure:
self.kafka.authorizer_class_name = KafkaService.ACL_AUTHORIZER self.kafka.authorizer_class_name = KafkaService.ZK_ACL_AUTHORIZER
# Force use of direct ZooKeeper access because Kafka is not yet started # Force use of direct ZooKeeper access because Kafka is not yet started
self.acls.set_acls(security_protocol, self.kafka, self.topic, self.group, force_use_zk_connection=True, self.acls.set_acls(security_protocol, self.kafka, self.topic, self.group, force_use_zk_connection=True,
additional_cluster_operations_to_grant=['Create']) additional_cluster_operations_to_grant=['Create'])