File tree Expand file tree Collapse file tree 1 file changed +2
-0
lines changed
core/src/test/scala/integration/kafka/api Expand file tree Collapse file tree 1 file changed +2
-0
lines changed Original file line number Diff line number Diff line change @@ -23,6 +23,7 @@ import org.apache.kafka.clients.consumer._
2323import org .apache .kafka .clients .producer .{KafkaProducer , ProducerRecord }
2424import org .apache .kafka .common .TopicPartition
2525import org .apache .kafka .common .errors .{InvalidProducerEpochException , ProducerFencedException , TimeoutException }
26+ import org .apache .kafka .common .test .api .Flaky
2627import org .apache .kafka .coordinator .group .GroupCoordinatorConfig
2728import org .apache .kafka .coordinator .transaction .{TransactionLogConfig , TransactionStateManagerConfig }
2829import org .apache .kafka .server .config .{ReplicationConfigs , ServerConfigs , ServerLogConfigs }
@@ -709,6 +710,7 @@ class TransactionsTest extends IntegrationTestHarness {
709710 assertThrows(classOf [IllegalStateException ], () => producer.initTransactions())
710711 }
711712
713+ @ Flaky (" KAFKA-18035" )
712714 @ ParameterizedTest
713715 @ CsvSource (Array (
714716 " kraft,classic,false" ,
You can’t perform that action at this time.
0 commit comments