Reset metadata_quorum annotations

apache · Oct 16, 2024 · 2d0494b · 2d0494b
1 parent 50311b9
commit 2d0494b
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/tests/kafkatest/tests/streams/streams_optimized_test.py b/tests/kafkatest/tests/streams/streams_optimized_test.py
@@ -56,7 +56,7 @@ def __init__(self, test_context):
                                            acks=1)
 
     @cluster(num_nodes=9)
-    @matrix(metadata_quorum=[quorum.combined_kraft])
+    @matrix(metadata_quorum=[quorum.isolated_kraft])
     def test_upgrade_optimized_topology(self, metadata_quorum):
         self.kafka.start()
 

diff --git a/tests/kafkatest/tests/streams/streams_relational_smoke_test.py b/tests/kafkatest/tests/streams/streams_relational_smoke_test.py
@@ -87,7 +87,7 @@ def __init__(self, test_context):
     @cluster(num_nodes=8)
     @matrix(crash=[False, True],
             processing_guarantee=['exactly_once_v2'],
-            metadata_quorum=[quorum.combined_kraft])
+            metadata_quorum=[quorum.isolated_kraft])
     def test_streams(self, crash, processing_guarantee, metadata_quorum):
         driver = StreamsRelationalSmokeTestService(self.test_context, self.kafka, "driver", "ignored", "ignored")
 

diff --git a/tests/kafkatest/tests/streams/streams_shutdown_deadlock_test.py b/tests/kafkatest/tests/streams/streams_shutdown_deadlock_test.py
@@ -33,7 +33,7 @@ def __init__(self, test_context):
         self.driver = StreamsSmokeTestShutdownDeadlockService(test_context, self.kafka)
 
     @cluster(num_nodes=3)
-    @matrix(metadata_quorum=[quorum.combined_kraft])
+    @matrix(metadata_quorum=[quorum.isolated_kraft])
     def test_shutdown_wont_deadlock(self, metadata_quorum):
         """
         Start ShutdownDeadLockTest, wait for upt to 1 minute, and check that the process exited.