Merge pull request #2570 from ozangunalp/kafka_flaky_test

Disable Kafka MultiSplitterTest flaky test
smallrye · Apr 9, 2024 · 8b5ff3a · 8b5ff3a
2 parents 60c1143 + 976e8ae
commit 8b5ff3a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/...ing-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/split/MultiSplitterTest.java b/...ing-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/split/MultiSplitterTest.java
@@ -12,6 +12,7 @@
 import org.apache.kafka.clients.consumer.ConsumerRecord;
 import org.eclipse.microprofile.reactive.messaging.Incoming;
 import org.eclipse.microprofile.reactive.messaging.Outgoing;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 
 import io.smallrye.mutiny.Multi;
@@ -20,6 +21,7 @@
 import io.smallrye.reactive.messaging.kafka.base.KafkaMapBasedConfig;
 import io.smallrye.reactive.messaging.kafka.companion.ConsumerTask;
 
+@Disabled("Fails on CI")
 class MultiSplitterTest extends KafkaCompanionTestBase {
 
     @Test
@@ -40,7 +42,7 @@ public void sink() {
                 .awaitCompletion();
         assertThat(records)
                 .extracting(ConsumerRecord::value)
-                .containsSequence(IntStream.range(1, 1500).map(i -> i * 2).mapToObj(String::valueOf)
+                .containsSequence(IntStream.range(1, 1501).map(i -> i * 2).mapToObj(String::valueOf)
                         .collect(Collectors.toList()));
 
         companion.consumeStrings()

diff --git a/smallrye-reactive-messaging-kafka/src/test/resources/log4j.properties b/smallrye-reactive-messaging-kafka/src/test/resources/log4j.properties
@@ -8,6 +8,7 @@ log4j.appender.stdout.layout.ConversionPattern=%d{HH:mm:ss,SSS} %-5p [%c] - %m%n
 log4j.logger.org.apache.kafka.clients=WARN
 log4j.logger.org.apache.kafka.common.utils=WARN
 log4j.logger.org.apache.kafka.common.metrics=WARN
+log4j.logger.org.apache.kafka.common.telemetry=WARN
 log4j.logger.io.smallrye.reactive.messaging=WARN
 log4j.logger.io.smallrye.reactive.messaging.kafka=WARN
 log4j.logger.io.smallrye.reactive.messaging.kafka.companion=WARN