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])
