You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by cm...@apache.org on 2021/03/10 19:06:16 UTC
[kafka] branch 2.8 updated: MINOR: Disable transactional/idempotent
system tests for Raft quorums (#10224)
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 711d925 MINOR: Disable transactional/idempotent system tests for Raft quorums (#10224)
711d925 is described below
commit 711d925d64ff19df1487c9057c4cd528e7535f41
Author: Ron Dagostino <rd...@confluent.io>
AuthorDate: Tue Mar 2 12:57:12 2021 -0500
MINOR: Disable transactional/idempotent system tests for Raft quorums (#10224)
---
tests/kafkatest/tests/core/replication_test.py | 3 +--
tests/kafkatest/tests/streams/streams_smoke_test.py | 3 ++-
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/tests/kafkatest/tests/core/replication_test.py b/tests/kafkatest/tests/core/replication_test.py
index a0c0156..bc40c81 100644
--- a/tests/kafkatest/tests/core/replication_test.py
+++ b/tests/kafkatest/tests/core/replication_test.py
@@ -122,8 +122,7 @@ class ReplicationTest(EndToEndTest):
@matrix(failure_mode=["clean_shutdown", "hard_shutdown", "clean_bounce", "hard_bounce"],
broker_type=["leader"],
security_protocol=["PLAINTEXT"],
- enable_idempotence=[True],
- metadata_quorum=quorum.all_non_upgrade)
+ enable_idempotence=[True])
@matrix(failure_mode=["clean_shutdown", "hard_shutdown", "clean_bounce", "hard_bounce"],
broker_type=["leader"],
security_protocol=["PLAINTEXT", "SASL_SSL"],
diff --git a/tests/kafkatest/tests/streams/streams_smoke_test.py b/tests/kafkatest/tests/streams/streams_smoke_test.py
index b1f908d..29955cd 100644
--- a/tests/kafkatest/tests/streams/streams_smoke_test.py
+++ b/tests/kafkatest/tests/streams/streams_smoke_test.py
@@ -47,7 +47,8 @@ class StreamsSmokeTest(KafkaTest):
self.driver = StreamsSmokeTestDriverService(test_context, self.kafka)
@cluster(num_nodes=8)
- @matrix(processing_guarantee=['at_least_once', 'exactly_once', 'exactly_once_beta'], crash=[True, False], metadata_quorum=quorum.all_non_upgrade)
+ @matrix(processing_guarantee=['at_least_once'], crash=[True, False], metadata_quorum=quorum.all_non_upgrade)
+ @matrix(processing_guarantee=['exactly_once', 'exactly_once_beta'], crash=[True, False])
def test_streams(self, processing_guarantee, crash, metadata_quorum=quorum.zk):
processor1 = StreamsSmokeTestJobRunnerService(self.test_context, self.kafka, processing_guarantee)
processor2 = StreamsSmokeTestJobRunnerService(self.test_context, self.kafka, processing_guarantee)