diff --git a/tests/kafkatest/tests/client/quota_test.py b/tests/kafkatest/tests/client/quota_test.py index 204cabbecdf41..595f64d20b006 100644 --- a/tests/kafkatest/tests/client/quota_test.py +++ b/tests/kafkatest/tests/client/quota_test.py @@ -77,9 +77,10 @@ def __init__(self, quota_type, override_quota, kafka): 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])