Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-4815 Idempotent/transactional Producer (KIP-98)
  3. KAFKA-5231

TransactinoCoordinator does not bump epoch when aborting open transactions

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • Blocker
    • Resolution: Fixed
    • None
    • 0.11.0.0
    • None

    Description

      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.

      Attachments

        Activity

          People

            guozhang Guozhang Wang
            apurva Apurva Mehta
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: