This is an automated email from the ASF dual-hosted git repository. rsivaram pushed a commit to branch 2.7 in repository https://gitbox.apache.org/repos/asf/kafka.git
commit 351b84d3c78766ee36097ea569eacadd8b7f77e4 Author: Ron Dagostino <rdagost...@confluent.io> AuthorDate: Thu Oct 15 12:08:42 2020 -0400 MINOR: fix error in quota_test.py system tests (#9443) --- tests/kafkatest/tests/client/quota_test.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/tests/kafkatest/tests/client/quota_test.py b/tests/kafkatest/tests/client/quota_test.py index 204cabb..595f64d 100644 --- a/tests/kafkatest/tests/client/quota_test.py +++ b/tests/kafkatest/tests/client/quota_test.py @@ -77,9 +77,10 @@ class QuotaConfig(object): self.configure_quota(kafka, QuotaConfig.LARGE_QUOTA, QuotaConfig.LARGE_QUOTA, ['clients', None]) def configure_quota(self, kafka, producer_byte_rate, consumer_byte_rate, entity_args): + force_use_zk_conection = not kafka.all_nodes_configs_command_uses_bootstrap_server() node = kafka.nodes[0] cmd = "%s %s --alter --add-config producer_byte_rate=%d,consumer_byte_rate=%d" % \ - (kafka.path.script("kafka-configs.sh", node), kafka._connect_setting_kafka_configs(node), producer_byte_rate, consumer_byte_rate) + (kafka.kafka_configs_cmd_with_optional_security_settings(node, force_use_zk_conection), producer_byte_rate, consumer_byte_rate) cmd += " --entity-type " + entity_args[0] + self.entity_name_opt(entity_args[1]) if len(entity_args) > 2: cmd += " --entity-type " + entity_args[2] + self.entity_name_opt(entity_args[3])