kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rsiva...@apache.org
Subject [kafka] 02/02: MINOR: fix error in quota_test.py system tests (#9443)
Date Thu, 15 Oct 2020 21:15:18 GMT
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 <rdagostino@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])


Mime
View raw message