dmvk commented on a change in pull request #16941: URL: https://github.com/apache/flink/pull/16941#discussion_r700175231
########## File path: docs/content/docs/connectors/datastream/kafka.md ########## @@ -848,4 +848,9 @@ clash with the ones that have already been used by other applications. In most cases, those applications are also Flink jobs running the same job graph, since the IDs are generated using the same logic, prefixed with `taskName + "-" + operatorUid`, by default. To solve the problem, you can use `setTransactionalIdPrefix()` to override this logic and specify different `transactional.id` prefixes for different jobs. +Other reason for this exception may be a transaction timeout on the broker side. After implementation of +[KAFKA-6119](https://issues.apache.org/jira/browse/KAFKA-6119), `(producerId, epoch)` is fenced +after transaction timeout and all of its pending transactions are aborted (each `transactional.id` is +mapped to a single `producerId`, this is described in more details in the following [blog post](https://www.confluent.io/blog/simplified-robust-exactly-one-semantics-in-kafka-2-5/)). Review comment: :+1: -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
