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

KafkaProducer with transactionId endless waits when network is disconnection for 10-20s

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 2.1.0
    • Fix Version/s: 2.3.0
    • Component/s: clients, producer
    • Labels:
      None

      Description

      When the client disconnect with the bootstrap server, a KafkaProducer with transactionId endless waits on commitTransaction, the question is the same with below issues:

      https://issues.apache.org/jira/browse/KAFKA-6446

      the reproduce condition you can do it as belows:

      1、producer.initTransactions();

      2、producer.beginTransaction();

      3、producer.send(record1);//set the breakpoint here

      key step: run the breakpoint above 3 then disconnect the network by manual, 10-20seconds recover the network and continute the program by canceling the breakpoint

      4、producer.send(record2);

      5、producer.commitTransaction();//endless waits

       

      I found in 2.1.0 version the modificaiton about the initTransactions method, but the 

      commitTransaction and abortTransaction method, I think it's the same question with initTransactions...

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                huxi_2b huxihx
                Reporter:
                weasker weasker
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - 72h
                  72h
                  Remaining:
                  Remaining Estimate - 72h
                  72h
                  Logged:
                  Time Spent - Not Specified
                  Not Specified