Rebase to trunk, update to remove dynamicRaftQuorum=True

apache · Sep 30, 2024 · ec294cf · ec294cf
1 parent 90d8a68
commit ec294cf
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 4 deletions.
diff --git a/tests/kafkatest/tests/kafka_test.py b/tests/kafkatest/tests/kafka_test.py
@@ -39,8 +39,7 @@ def __init__(self, test_context, num_zk, num_brokers, topics=None):
         self.kafka = KafkaService(
             test_context, self.num_brokers,
             self.zk, topics=self.topics,
-            controller_num_nodes_override=self.num_zk,
-            dynamicRaftQuorum=True)
+            controller_num_nodes_override=self.num_zk)
 
     def setUp(self):
         if self.zk:

diff --git a/tests/kafkatest/tests/streams/streams_application_upgrade_test.py b/tests/kafkatest/tests/streams/streams_application_upgrade_test.py
@@ -82,7 +82,7 @@ def test_app_upgrade(self, from_version, bounce_type, metadata_quorum):
             'avg' : { 'partitions': 5, 'replication-factor': 1 },
             'wcnt' : { 'partitions': 5, 'replication-factor': 1 },
             'tagg' : { 'partitions': 5, 'replication-factor': 1 }
-        }, controller_num_nodes_override=1, dynamicRaftQuorum=True)
+        }, controller_num_nodes_override=1)
         self.kafka.start()
 
         self.driver = StreamsSmokeTestDriverService(self.test_context, self.kafka)

diff --git a/tests/kafkatest/tests/streams/streams_broker_bounce_test.py b/tests/kafkatest/tests/streams/streams_broker_bounce_test.py
@@ -153,7 +153,7 @@ def setup_system(self, start_processor=True, num_threads=3):
         # Setup phase
 
         self.kafka = KafkaService(self.test_context, num_nodes=3, zk=None, topics=self.topics,
-                                  controller_num_nodes_override=1, dynamicRaftQuorum=True)
+                                  controller_num_nodes_override=1)
         self.kafka.start()
 
         # allow some time for topics to be created