Removed unnecessary test repetitions

smallrye · Dec 5, 2023 · e2a37f2 · e2a37f2
1 parent 85e8b9a
commit e2a37f2
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 9 deletions.
diff --git a/...e-messaging-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/MultiTopicsTest.java b/...e-messaging-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/MultiTopicsTest.java
@@ -18,7 +18,6 @@
 import org.apache.kafka.common.serialization.StringDeserializer;
 import org.eclipse.microprofile.reactive.messaging.Incoming;
 import org.eclipse.microprofile.reactive.messaging.Message;
-import org.junit.jupiter.api.RepeatedTest;
 import org.junit.jupiter.api.Test;
 
 import io.smallrye.reactive.messaging.kafka.api.IncomingKafkaRecordMetadata;
@@ -31,7 +30,7 @@
 @SuppressWarnings("rawtypes")
 public class MultiTopicsTest extends KafkaCompanionTestBase {
 
-    @RepeatedTest(5)
+    @Test
     public void testWithThreeTopicsInConfiguration() {
         String topic1 = UUID.randomUUID().toString();
         String topic2 = UUID.randomUUID().toString();
@@ -83,7 +82,7 @@ public void testWithThreeTopicsInConfiguration() {
         assertThat(top3.get()).isGreaterThanOrEqualTo(3);
     }
 
-    @RepeatedTest(5)
+    @Test
     public void testWithOnlyTwoTopicsReceiving() {
         String topic1 = UUID.randomUUID().toString();
         String topic2 = UUID.randomUUID().toString();

diff --git a/.../src/test/java/io/smallrye/reactive/messaging/kafka/commit/BatchCommitStrategiesTest.java b/.../src/test/java/io/smallrye/reactive/messaging/kafka/commit/BatchCommitStrategiesTest.java
@@ -19,7 +19,6 @@
 import org.eclipse.microprofile.reactive.messaging.Message;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.RepeatedTest;
 import org.junit.jupiter.api.Test;
 
 import io.smallrye.common.annotation.Identifier;
@@ -189,7 +188,7 @@ void testThrottledStrategy() {
 
     }
 
-    @RepeatedTest(10)
+    @Test
     void testThrottledStrategyWithManyRecords() {
         MapBasedConfig config = commonConfiguration()
                 .with("lazy-client", true)

diff --git a/...kafka/src/test/java/io/smallrye/reactive/messaging/kafka/commit/CommitStrategiesTest.java b/...kafka/src/test/java/io/smallrye/reactive/messaging/kafka/commit/CommitStrategiesTest.java
@@ -22,7 +22,6 @@
 import org.eclipse.microprofile.reactive.messaging.Message;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.RepeatedTest;
 import org.junit.jupiter.api.Test;
 
 import io.smallrye.common.annotation.Identifier;
@@ -225,7 +224,7 @@ void testThrottledStrategy() {
 
     }
 
-    @RepeatedTest(10)
+    @Test
     void testThrottledStrategyWithManyRecords() {
         MapBasedConfig config = commonConfiguration()
                 .with("lazy-client", true)

diff --git a/...saging-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/commit/RebalanceTest.java b/...saging-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/commit/RebalanceTest.java
@@ -15,7 +15,7 @@
 import org.eclipse.microprofile.reactive.messaging.Message;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.RepeatedTest;
+import org.junit.jupiter.api.Test;
 
 import io.smallrye.reactive.messaging.health.HealthReport;
 import io.smallrye.reactive.messaging.kafka.*;
@@ -47,7 +47,7 @@ void closing() {
         vertx.closeAndAwait();
     }
 
-    @RepeatedTest(10)
+    @Test
     void testRebalance() throws InterruptedException {
         String group = UUID.randomUUID().toString();
         MapBasedConfig config = commonConfiguration()