[kafka] branch 2.8 updated: MINOR: disable round_trip_fault_test system tests for Raft quorums (#10249)

[cm...@apache.org]

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

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


The following commit(s) were added to refs/heads/2.8 by this push:
     new 1b5cdd1  MINOR: disable round_trip_fault_test system tests for Raft quorums (#10249)
1b5cdd1 is described below

commit 1b5cdd182ec06098d55c51edffa0cb486dc0a760
Author: Ron Dagostino <rd...@confluent.io>
AuthorDate: Tue Mar 9 16:57:15 2021 -0500

    MINOR: disable round_trip_fault_test system tests for Raft quorums (#10249)
    
    The KIP-500 early access release will not support creating a partition with a manual
    partition assignment that includes a broker that is not currently online. This patch disables
    system tests for Raft-based metadata quorums where the test depends on this functionality
    to pass.
    
    Reviewers: Colin P. McCabe <cm...@apache.org>
---
 tests/kafkatest/tests/core/round_trip_fault_test.py | 5 -----
 1 file changed, 5 deletions(-)

diff --git a/tests/kafkatest/tests/core/round_trip_fault_test.py b/tests/kafkatest/tests/core/round_trip_fault_test.py
index b9085cb..d8873b2 100644
--- a/tests/kafkatest/tests/core/round_trip_fault_test.py
+++ b/tests/kafkatest/tests/core/round_trip_fault_test.py
@@ -75,13 +75,11 @@ class RoundTripFaultTest(Test):
             return []
 
     @cluster(num_nodes=9)
-    @matrix(metadata_quorum=quorum.all_non_upgrade)
     def test_round_trip_workload(self, metadata_quorum=quorum.zk):
         workload1 = self.trogdor.create_task("workload1", self.round_trip_spec)
         workload1.wait_for_done(timeout_sec=600)
 
     @cluster(num_nodes=9)
-    @matrix(metadata_quorum=quorum.all_non_upgrade)
     def test_round_trip_workload_with_broker_partition(self, metadata_quorum=quorum.zk):
         workload1 = self.trogdor.create_task("workload1", self.round_trip_spec)
         time.sleep(2)
@@ -95,7 +93,6 @@ class RoundTripFaultTest(Test):
         partition1.wait_for_done()
 
     @cluster(num_nodes=9)
-    @matrix(metadata_quorum=quorum.all_non_upgrade)
     def test_produce_consume_with_broker_pause(self, metadata_quorum=quorum.zk):
         workload1 = self.trogdor.create_task("workload1", self.round_trip_spec)
         time.sleep(2)
@@ -108,7 +105,6 @@ class RoundTripFaultTest(Test):
         self.kafka.stop_node(self.kafka.nodes[0], False)
 
     @cluster(num_nodes=9)
-    @matrix(metadata_quorum=quorum.all_non_upgrade)
     def test_produce_consume_with_client_partition(self, metadata_quorum=quorum.zk):
         workload1 = self.trogdor.create_task("workload1", self.round_trip_spec)
         time.sleep(2)
@@ -121,7 +117,6 @@ class RoundTripFaultTest(Test):
         stop1.wait_for_done()
 
     @cluster(num_nodes=9)
-    @matrix(metadata_quorum=quorum.all_non_upgrade)
     def test_produce_consume_with_latency(self, metadata_quorum=quorum.zk):
         workload1 = self.trogdor.create_task("workload1", self.round_trip_spec)
         time.sleep(2)