This is an automated email from the ASF dual-hosted git repository.
davidarthur pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 8f63a77ba1d MINOR quarantine flaky tests for Nov 18, 2024 (#17845)
8f63a77ba1d is described below
commit 8f63a77ba1d53b496a3310361e04393ded827519
Author: David Arthur <[email protected]>
AuthorDate: Mon Nov 18 16:56:12 2024 -0500
MINOR quarantine flaky tests for Nov 18, 2024 (#17845)
---
core/src/test/java/kafka/test/api/ShareConsumerTest.java | 10 ++++++++++
.../test/scala/integration/kafka/api/BaseConsumerTest.scala | 2 ++
.../scala/integration/kafka/api/PlaintextConsumerTest.scala | 2 ++
.../test/scala/integration/kafka/api/TransactionsTest.scala | 3 +++
4 files changed, 17 insertions(+)
diff --git a/core/src/test/java/kafka/test/api/ShareConsumerTest.java
b/core/src/test/java/kafka/test/api/ShareConsumerTest.java
index ed8fee0a01f..fca9cffca86 100644
--- a/core/src/test/java/kafka/test/api/ShareConsumerTest.java
+++ b/core/src/test/java/kafka/test/api/ShareConsumerTest.java
@@ -51,6 +51,7 @@ import org.apache.kafka.common.serialization.Deserializer;
import org.apache.kafka.common.serialization.Serializer;
import org.apache.kafka.common.test.KafkaClusterTestKit;
import org.apache.kafka.common.test.TestKitNodes;
+import org.apache.kafka.common.test.api.Flaky;
import org.apache.kafka.coordinator.group.GroupConfig;
import org.apache.kafka.test.TestUtils;
@@ -276,6 +277,7 @@ public class ShareConsumerTest {
}
}
+ @Flaky("KAFKA-18033")
@ParameterizedTest(name = "{displayName}.persister={0}")
@ValueSource(strings = {NO_OP_PERSISTER, DEFAULT_STATE_PERSISTER})
public void testAcknowledgementSentOnSubscriptionChange(String persister)
throws ExecutionException, InterruptedException {
@@ -372,6 +374,7 @@ public class ShareConsumerTest {
}
}
+ @Flaky("KAFKA-18033")
@ParameterizedTest(name = "{displayName}.persister={0}")
@ValueSource(strings = {NO_OP_PERSISTER, DEFAULT_STATE_PERSISTER})
public void
testAcknowledgementCommitCallbackInvalidRecordStateException(String persister)
throws Exception {
@@ -598,6 +601,7 @@ public class ShareConsumerTest {
}
}
+ @Flaky("KAFKA-18033")
@ParameterizedTest(name = "{displayName}.persister={0}")
@ValueSource(strings = {NO_OP_PERSISTER, DEFAULT_STATE_PERSISTER})
public void testExplicitAcknowledgementCommitAsync(String persister)
throws InterruptedException {
@@ -654,6 +658,7 @@ public class ShareConsumerTest {
}
}
+ @Flaky("KAFKA-18033")
@ParameterizedTest(name = "{displayName}.persister={0}")
@ValueSource(strings = {NO_OP_PERSISTER, DEFAULT_STATE_PERSISTER})
public void testExplicitAcknowledgementCommitAsyncPartialBatch(String
persister) {
@@ -760,6 +765,7 @@ public class ShareConsumerTest {
}
}
+ @Flaky("KAFKA-18033")
@ParameterizedTest(name = "{displayName}.persister={0}")
@ValueSource(strings = {NO_OP_PERSISTER, DEFAULT_STATE_PERSISTER})
public void testExplicitAcknowledgeReleaseClose(String persister) {
@@ -993,6 +999,7 @@ public class ShareConsumerTest {
}
}
+ @Flaky("KAFKA-18033")
@ParameterizedTest(name = "{displayName}.persister={0}")
@ValueSource(strings = {NO_OP_PERSISTER, DEFAULT_STATE_PERSISTER})
public void testMultipleConsumersInGroupConcurrentConsumption(String
persister) {
@@ -1366,6 +1373,7 @@ public class ShareConsumerTest {
* Test to verify that the acknowledgement commit callback can invoke
KafkaShareConsumer.wakeup() and it
* wakes up the enclosing poll.
*/
+ @Flaky("KAFKA-18033")
@ParameterizedTest(name = "{displayName}.persister={0}")
@ValueSource(strings = {NO_OP_PERSISTER, DEFAULT_STATE_PERSISTER})
public void testAcknowledgeCommitCallbackCallsShareConsumerWakeup(String
persister) throws InterruptedException {
@@ -1418,6 +1426,7 @@ public class ShareConsumerTest {
* Test to verify that the acknowledgement commit callback can throw an
exception, and it is propagated
* to the caller of poll().
*/
+ @Flaky("KAFKA-18033")
@ParameterizedTest(name = "{displayName}.persister={0}")
@ValueSource(strings = {NO_OP_PERSISTER, DEFAULT_STATE_PERSISTER})
public void testAcknowledgeCommitCallbackThrowsException(String persister)
throws InterruptedException {
@@ -1664,6 +1673,7 @@ public class ShareConsumerTest {
}
}
+ @Flaky("KAFKA-18033")
@ParameterizedTest(name = "{displayName}.persister={0}")
@ValueSource(strings = {NO_OP_PERSISTER, DEFAULT_STATE_PERSISTER})
public void testShareAutoOffsetResetDefaultValue(String persister) {
diff --git a/core/src/test/scala/integration/kafka/api/BaseConsumerTest.scala
b/core/src/test/scala/integration/kafka/api/BaseConsumerTest.scala
index 1d98552d1cd..a7e7424191a 100644
--- a/core/src/test/scala/integration/kafka/api/BaseConsumerTest.scala
+++ b/core/src/test/scala/integration/kafka/api/BaseConsumerTest.scala
@@ -23,6 +23,7 @@ import org.apache.kafka.common.header.Headers
import org.apache.kafka.common.{ClusterResource, ClusterResourceListener,
PartitionInfo}
import org.apache.kafka.common.internals.Topic
import org.apache.kafka.common.serialization.{ByteArrayDeserializer,
ByteArraySerializer, Deserializer, Serializer}
+import org.apache.kafka.common.test.api.Flaky
import org.junit.jupiter.api.Assertions._
import org.junit.jupiter.params.ParameterizedTest
import org.junit.jupiter.params.provider.MethodSource
@@ -79,6 +80,7 @@ abstract class BaseConsumerTest extends AbstractConsumerTest {
assertNotEquals(0, BaseConsumerTest.updateConsumerCount.get())
}
+ @Flaky("KAFKA-15920")
@ParameterizedTest(name =
TestInfoUtils.TestWithParameterizedQuorumAndGroupProtocolNames)
@MethodSource(Array("getTestQuorumAndGroupProtocolParametersAll"))
def testCoordinatorFailover(quorum: String, groupProtocol: String): Unit = {
diff --git
a/core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala
b/core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala
index cbf763ec581..91544011ea8 100644
--- a/core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala
+++ b/core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala
@@ -27,6 +27,7 @@ import org.apache.kafka.common.config.TopicConfig
import org.apache.kafka.common.errors.{InterruptException,
InvalidGroupIdException, InvalidTopicException, TimeoutException,
WakeupException}
import org.apache.kafka.common.record.{CompressionType, TimestampType}
import org.apache.kafka.common.serialization._
+import org.apache.kafka.common.test.api.Flaky
import org.apache.kafka.common.{MetricName, TopicPartition}
import org.apache.kafka.server.quota.QuotaType
import org.apache.kafka.test.{MockConsumerInterceptor, MockProducerInterceptor}
@@ -825,6 +826,7 @@ class PlaintextConsumerTest extends BaseConsumerTest {
assertThrows(classOf[WakeupException], () =>
consumer.position(topicPartition, Duration.ofSeconds(100)))
}
+ @Flaky("KAFKA-18031")
@ParameterizedTest(name =
TestInfoUtils.TestWithParameterizedQuorumAndGroupProtocolNames)
@MethodSource(Array("getTestQuorumAndGroupProtocolParametersAll"))
def testCloseLeavesGroupOnInterrupt(quorum: String, groupProtocol: String):
Unit = {
diff --git a/core/src/test/scala/integration/kafka/api/TransactionsTest.scala
b/core/src/test/scala/integration/kafka/api/TransactionsTest.scala
index 0c9c1f2cabc..3a30dfe00e3 100644
--- a/core/src/test/scala/integration/kafka/api/TransactionsTest.scala
+++ b/core/src/test/scala/integration/kafka/api/TransactionsTest.scala
@@ -23,6 +23,7 @@ import org.apache.kafka.clients.consumer.{Consumer,
ConsumerConfig, ConsumerGrou
import org.apache.kafka.clients.producer.{KafkaProducer, ProducerRecord}
import org.apache.kafka.common.TopicPartition
import org.apache.kafka.common.errors.{InvalidProducerEpochException,
ProducerFencedException, TimeoutException}
+import org.apache.kafka.common.test.api.Flaky
import org.apache.kafka.coordinator.group.GroupCoordinatorConfig
import org.apache.kafka.coordinator.transaction.{TransactionLogConfig,
TransactionStateManagerConfig}
import org.apache.kafka.server.config.{ReplicationConfigs, ServerConfigs,
ServerLogConfigs}
@@ -173,6 +174,7 @@ class TransactionsTest extends IntegrationTestHarness {
}
}
+ @Flaky("KAFKA-18036")
@ParameterizedTest(name =
TestInfoUtils.TestWithParameterizedQuorumAndGroupProtocolNames)
@MethodSource(Array("getTestQuorumAndGroupProtocolParametersAll"))
def testReadCommittedConsumerShouldNotSeeUndecidedData(quorum: String,
groupProtocol: String): Unit = {
@@ -697,6 +699,7 @@ class TransactionsTest extends IntegrationTestHarness {
assertThrows(classOf[IllegalStateException], () =>
producer.initTransactions())
}
+ @Flaky("KAFKA-18035,KAFKA-18036")
@ParameterizedTest
@CsvSource(Array(
"kraft,classic,false",
