rebased from trunk - trying to see if quorum types affect consistentl…

…y failing test
apache · Nov 4, 2024 · d81fcfc · d81fcfc
1 parent 4c5b487
commit d81fcfc
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/tests/kafkatest/tests/streams/streams_broker_bounce_test.py b/tests/kafkatest/tests/streams/streams_broker_bounce_test.py
@@ -207,7 +207,7 @@ def collect_results(self, sleep_time_secs):
             broker_type=["leader"],
             num_threads=[1, 3],
             sleep_time_secs=[120],
-            metadata_quorum=[quorum.combined_kraft])
+            metadata_quorum=[quorum.isolated_kraft])
     def test_broker_type_bounce(self, failure_mode, broker_type, sleep_time_secs, num_threads, metadata_quorum):
         """
         Start a smoke test client, then kill one particular broker and ensure data is still received
@@ -252,7 +252,7 @@ def test_broker_type_bounce_at_start(self, failure_mode, broker_type, sleep_time
     @cluster(num_nodes=7)
     @matrix(failure_mode=["clean_shutdown", "hard_shutdown", "clean_bounce", "hard_bounce"],
             num_failures=[2],
-            metadata_quorum=[quorum.combined_kraft])
+            metadata_quorum=[quorum.isolated_kraft])
     def test_many_brokers_bounce(self, failure_mode, num_failures, metadata_quorum):
         """
         Start a smoke test client, then kill a few brokers and ensure data is still received
@@ -271,7 +271,7 @@ def test_many_brokers_bounce(self, failure_mode, num_failures, metadata_quorum):
     @cluster(num_nodes=7)
     @matrix(failure_mode=["clean_bounce", "hard_bounce"],
             num_failures=[3],
-            metadata_quorum=[quorum.combined_kraft])
+            metadata_quorum=[quorum.isolated_kraft])
     def test_all_brokers_bounce(self, failure_mode, num_failures, metadata_quorum):
         """
         Start a smoke test client, then kill a few brokers and ensure data is still received