From c7f19aba37150371c7fbaa41e3480c85f564beb4 Mon Sep 17 00:00:00 2001 From: Ron Dagostino Date: Tue, 20 Oct 2020 08:13:50 -0400 Subject: [PATCH] MINOR: fix system tests sending ACLs through ZooKeeper (#9458) Reviewers: Rajini Sivaram --- tests/kafkatest/services/security/kafka_acls.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/tests/kafkatest/services/security/kafka_acls.py b/tests/kafkatest/services/security/kafka_acls.py index 96438bc7e2d..dcab2715964 100644 --- a/tests/kafkatest/services/security/kafka_acls.py +++ b/tests/kafkatest/services/security/kafka_acls.py @@ -50,7 +50,7 @@ class ACLs: :param force_use_zk_connection: forces the use of ZooKeeper when true, otherwise AdminClient is used when available """ cmd = "%(cmd_prefix)s --add --topic=%(topic)s %(operation_flag)s --allow-principal=%(principal)s" % { - 'cmd_prefix': kafka.kafka_acls_cmd_with_optional_security_settings(kafka, node, force_use_zk_connection), + 'cmd_prefix': kafka.kafka_acls_cmd_with_optional_security_settings(node, force_use_zk_connection), 'topic': topic, 'operation_flag': operation_flag, 'principal': principal @@ -71,7 +71,7 @@ class ACLs: for operation in ['ClusterAction'] + additional_cluster_operations_to_grant: cmd = "%(cmd_prefix)s --add --cluster --operation=%(operation)s --allow-principal=%(principal)s" % { - 'cmd_prefix': kafka.kafka_acls_cmd_with_optional_security_settings(kafka, node, force_use_zk_connection), + 'cmd_prefix': kafka.kafka_acls_cmd_with_optional_security_settings(node, force_use_zk_connection), 'operation': operation, 'principal': principal } @@ -116,7 +116,7 @@ class ACLs: node = kafka.nodes[0] cmd = "%(cmd_prefix)s --add --topic=%(topic)s --group=%(group)s --consumer --allow-principal=%(principal)s" % { - 'cmd_prefix': kafka.kafka_acls_cmd_with_optional_security_settings(kafka, node, force_use_zk_connection), + 'cmd_prefix': kafka.kafka_acls_cmd_with_optional_security_settings(node, force_use_zk_connection), 'topic': topic, 'group': group, 'principal': principal