[jira] [Commented] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[Yordan Pavlov (Jira)]

Title: Message Title

Yordan Pavlov commented on FLINK-16419   Re: Avoid to recommit transactions which are known committed successfully to Kafka upon recovery Martijn Visser  As advised I have switched to KafkaSink and Flink 1.14.2. However I am still seeing the following error on recovering from a checkpoint: switched from INITIALIZING to FAILED with failure cause: org.apache.kafka.common.KafkaException: Unhandled error in EndTxnResponse: The producer attempted to use a producer id which is not currently assigned to its transactional id.     at org.apache.kafka.clients.producer.internals.TransactionManager$EndTxnHandler.handleResponse(TransactionManager.java:1362)     at org.apache.kafka.clients.producer.internals.TransactionManager$TxnRequestHandler.onComplete(TransactionManager.java:1074)     at org.apache.kafka.clients.ClientResponse.onComplete(ClientResponse.java:109)     at org.apache.kafka.clients.NetworkClient.completeResponses(NetworkClient.java:569)     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:561)     at org.apache.kafka.clients.producer.internals.Sender.maybeSendAndPollTransactionalRequest(Sender.java:425)     at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:311)     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:244)     at java.base/java.lang.Thread.run(Unknown Source) Add Comment   This message was sent by Atlassian Jira (v8.20.10#820010-sha1:ace47f9)