You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ce...@apache.org on 2024/07/06 00:31:12 UTC
(kafka) 01/01: Repeat testMultiNodeCluster case 25 times
This is an automated email from the ASF dual-hosted git repository.
cegerton pushed a commit to branch test-fix-dedicated-mirror-integration-test-multi-node-cluster
in repository https://gitbox.apache.org/repos/asf/kafka.git
commit f8418d4fdea1b989356b74e7e73462ecfa9cd8aa
Author: Chris Egerton <ch...@aiven.io>
AuthorDate: Fri Jul 5 20:31:01 2024 -0400
Repeat testMultiNodeCluster case 25 times
---
.../connect/mirror/integration/DedicatedMirrorIntegrationTest.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/DedicatedMirrorIntegrationTest.java b/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/DedicatedMirrorIntegrationTest.java
index 0a838632460..49ee36a8fcf 100644
--- a/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/DedicatedMirrorIntegrationTest.java
+++ b/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/DedicatedMirrorIntegrationTest.java
@@ -38,6 +38,7 @@ import org.apache.kafka.test.NoRetryException;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.RepeatedTest;
import org.junit.jupiter.api.Tag;
import org.junit.jupiter.api.Test;
import org.slf4j.Logger;
@@ -194,7 +195,7 @@ public class DedicatedMirrorIntegrationTest {
* See <a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-710%3A+Full+support+for+distributed+mode+in+dedicated+MirrorMaker+2.0+clusters">KIP-710</a>
* for more detail on the necessity for this test case.
*/
- @Test
+ @RepeatedTest(25)
public void testMultiNodeCluster() throws Exception {
Properties brokerProps = new Properties();
brokerProps.put("transaction.state.log.replication.factor", "1");