This is an automated email from the ASF dual-hosted git repository.
jolshan 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 f79d7dc3f4d KAFKA-18035: Readd flaky annotation back for
testBumpTransactionalEpochWithTV2Disabled (#18426)
f79d7dc3f4d is described below
commit f79d7dc3f4d8418561f8c89bfa7ad19e529005b8
Author: Justine Olshan <[email protected]>
AuthorDate: Wed Jan 8 09:06:41 2025 -0800
KAFKA-18035: Readd flaky annotation back for
testBumpTransactionalEpochWithTV2Disabled (#18426)
Reviewers: David Jacot <[email protected]>
---
core/src/test/scala/integration/kafka/api/TransactionsTest.scala | 2 ++
1 file changed, 2 insertions(+)
diff --git a/core/src/test/scala/integration/kafka/api/TransactionsTest.scala
b/core/src/test/scala/integration/kafka/api/TransactionsTest.scala
index 5c1edfe99b1..846f6413883 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._
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}
@@ -709,6 +710,7 @@ class TransactionsTest extends IntegrationTestHarness {
assertThrows(classOf[IllegalStateException], () =>
producer.initTransactions())
}
+ @Flaky("KAFKA-18035")
@ParameterizedTest
@CsvSource(Array(
"kraft,classic,false",
