MINOR: Mark`org.apache.kafka.streams.integration.EosIntegrationTest.shouldNotViolateEosIfOneTaskFails` as flaky (#20733)
Marks
`org.apache.kafka.streams.integration.EosIntegrationTest.shouldNotViolateEosIfOneTaskFails`
as flaky due to issues with test runs of the "streams" group protocol.
Ticket to resolve: https://issues.apache.org/jira/browse/KAFKA-19816
Reviewers: Lianet Magrans <lmagrans@confluent.io>, Chia-Ping Tsai
<chia7712@gmail.com>
diff --git a/build.gradle b/build.gradle
index a1768cf..6b7fefb 100644
--- a/build.gradle
+++ b/build.gradle
@@ -2900,6 +2900,7 @@
testImplementation libs.mockitoCore
testImplementation testLog4j2Libs
testImplementation project(':streams:test-utils')
+ testImplementation project(':test-common:test-common-util')
testRuntimeOnly runtimeTestLibs
}
diff --git a/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java b/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
index 46ace65..194025d 100644
--- a/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
+++ b/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
@@ -35,6 +35,7 @@
import org.apache.kafka.common.serialization.LongDeserializer;
import org.apache.kafka.common.serialization.LongSerializer;
import org.apache.kafka.common.serialization.Serdes;
+import org.apache.kafka.common.test.api.Flaky;
import org.apache.kafka.common.utils.Utils;
import org.apache.kafka.streams.KafkaStreams;
import org.apache.kafka.streams.KeyValue;
@@ -395,6 +396,7 @@
}
}
+ @Flaky("KAFKA-19816")
@ParameterizedTest
@MethodSource("groupProtocolAndProcessingThreadsParameters")
public void shouldNotViolateEosIfOneTaskFails(final String groupProtocol, final boolean processingThreadsEnabled) throws Exception {
