Apurva Mehta created KAFKA-5231: ----------------------------------- Summary: TransactinoCoordinator does not bump epoch when aborting open transactions Key: KAFKA-5231 URL: https://issues.apache.org/jira/browse/KAFKA-5231 Project: Kafka Issue Type: Bug Reporter: Apurva Mehta Assignee: Guozhang Wang Priority: Blocker Fix For: 0.11.0.0
When the TransactionCoordinator receives an InitPidRequest when there is an open transaction for a transactional id, it should first bump the epoch and then abort the open transaction. Currently, it aborts the open transaction with the existing epoch, hence the old producer is never fenced. -- This message was sent by Atlassian JIRA (v6.3.15#6346)