[
https://issues.apache.org/jira/browse/FLINK-40621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-40621:
-----------------------------------
Labels: test-stability (was: )
> FlinkKafkaInternalProducerITCase.testResetInnerTransactionIfFinalizingTransactionFailed
> fails with InvalidProducerEpochException instead of ProducerFencedException
> -------------------------------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-40621
> URL: https://issues.apache.org/jira/browse/FLINK-40621
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
> Affects Versions: kafka-5.1.0
> Reporter: Martijn Visser
> Priority: Major
> Labels: test-stability
>
> https://github.com/apache/flink-connector-kafka/actions/runs/34343298307/job/102495049319
> (PR #289, JDK 11, 2026-09-09; the PR does not touch this test or the
> producer)
> {code}
> [ERROR]
> org.apache.flink.connector.kafka.sink.FlinkKafkaInternalProducerITCase.testResetInnerTransactionIfFinalizingTransactionFailed(Consumer)[1]
> -- Time elapsed: 2.282 s <<< FAILURE!
> java.lang.AssertionError:
> Expecting actual throwable to be an instance of:
> org.apache.kafka.common.errors.ProducerFencedException
> but was:
> org.apache.kafka.common.errors.InvalidProducerEpochException: Producer with
> transactionalId 'dummy' and (producerId=0, epoch=0) attempted to produce with
> an old epoch
> at
> org.apache.flink.connector.kafka.sink.FlinkKafkaInternalProducerITCase.testResetInnerTransactionIfFinalizingTransactionFailed(FlinkKafkaInternalProducerITCase.java:171)
> {code}
> The other parameterization of the test passed in the same job.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
