Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-7887

Transaction Producer hanging when commiting/aborting transaction after a broker failure

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Duplicate
    • Affects Version/s: 2.0.1
    • Fix Version/s: None
    • Component/s: clients
    • Labels:
      None

      Description

      I have observed that when a broker fails, the issue with transactional producer hanging while trying to commit and/or abort transaction still persists

      Within TransactionalRequestResult.class lines 36-42

      while(!completed) {
            try {
              this.latch.await();
              completed = true;
            } catch (InterruptedException var3) {
            }
          }
      

      this.latch.await() never returns

      Reproducible by bringing down kafka broker while transactional producing is sending records

      Suggest (1) calling latch.await() with timeout parameter or (2) allow for easier overriding of method by developers to allow them to call await() with a timeout 

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                cameron.utsman Cameron
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: