This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a commit to branch 3.9
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/3.9 by this push:
new cbb8cfe520e KAFKA-18029 Fix quorum_reconfiguration_test.py (#17839)
cbb8cfe520e is described below
commit cbb8cfe520e0fbd33fe013e43b3245c8bacf7b75
Author: Ken Huang <[email protected]>
AuthorDate: Mon Nov 18 00:47:34 2024 +0800
KAFKA-18029 Fix quorum_reconfiguration_test.py (#17839)
Reviewers: Chia-Ping Tsai <[email protected]>
---
tests/kafkatest/services/kafka/kafka.py | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/tests/kafkatest/services/kafka/kafka.py
b/tests/kafkatest/services/kafka/kafka.py
index a74667cc830..6a23b6e6898 100644
--- a/tests/kafkatest/services/kafka/kafka.py
+++ b/tests/kafkatest/services/kafka/kafka.py
@@ -267,7 +267,7 @@ class KafkaService(KafkaPathResolverMixin, JmxMixin,
Service):
:param bool allow_zk_with_kraft: if True, then allow a KRaft broker or
controller to also use ZooKeeper
:param quorum_info_provider: A function that takes this KafkaService
as an argument and returns a ServiceQuorumInfo. If this is None, then the
ServiceQuorumInfo is generated from the test context
:param use_new_coordinator: When true, use the new implementation of
the group coordinator as per KIP-848. If this is None, the default existing
group coordinator is used.
- :param dynamicRaftQuorum: When true, the quorum uses kraft.version=1,
controller_quorum_bootstrap_servers, and bootstraps the first controller using
the standalone flag
+ :param dynamicRaftQuorum: When true,
controller_quorum_bootstrap_servers, and bootstraps the first controller using
the standalone flag
"""
self.zk = zk
@@ -913,7 +913,6 @@ class KafkaService(KafkaPathResolverMixin, JmxMixin,
Service):
kafka_storage_script = self.path.script("kafka-storage.sh", node)
cmd = "%s format --ignore-formatted --config %s --cluster-id %s" %
(kafka_storage_script, KafkaService.CONFIG_FILE, config_property.CLUSTER_ID)
if self.dynamicRaftQuorum:
- cmd += " --feature kraft.version=1"
if self.node_quorum_info.has_controller_role:
if self.standalone_controller_bootstrapped:
cmd += " --no-initial-controllers"
