Martijn Visser created FLINK-40621:
--------------------------------------
Summary:
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
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)
