[jira] [Created] (FLINK-40621) FlinkKafkaInternalProducerITCase.testResetInnerTransactionIfFinalizingTransactionFailed fails with InvalidProducerEpochException instead of ProducerFencedException

["Martijn Visser (Jira)" <ji...@apache.org>]

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)