This is an automated email from the ASF dual-hosted git repository.

chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new fde6ae1500a KAFKA-18029 remove the `kraft.version=1` from kafka.py 
(#17838)
fde6ae1500a is described below

commit fde6ae1500acf3ec0a953f4be62e6eb6e6335cf9
Author: Ken Huang <[email protected]>
AuthorDate: Mon Nov 18 00:48:19 2024 +0800

    KAFKA-18029 remove the `kraft.version=1` from kafka.py (#17838)
    
    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 07f5d44ef2c..acfa5c7f6c2 100644
--- a/tests/kafkatest/services/kafka/kafka.py
+++ b/tests/kafkatest/services/kafka/kafka.py
@@ -268,7 +268,7 @@ class KafkaService(KafkaPathResolverMixin, JmxMixin, 
Service):
         :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 consumer_group_migration_policy: The config that enables 
converting the non-empty classic group using the consumer embedded protocol to 
the non-empty consumer group using the consumer group protocol and vice versa.
-        :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
@@ -885,7 +885,6 @@ class KafkaService(KafkaPathResolverMixin, JmxMixin, 
Service):
                     if self.standalone_controller_bootstrapped:
                         cmd += " --no-initial-controllers"
                     else:
-                        cmd += " --feature kraft.version=1"
                         cmd += " --standalone"
                         self.standalone_controller_bootstrapped = True
             self.logger.info("Running log directory format command...\n%s" % 
cmd)

Reply via email to