[KAFKA-7887] Transaction Producer hanging when commiting/aborting transaction after a broker failure

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 2.0.1
• Component/s: clients
• Assignee: Unassigned
• Reporter: Cameron
• Created: 31/Jan/19 16:53
• Updated: 31/Jan/19 17:27
• Resolved: 31/Jan/19 17:25

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 

Issue Links

• is duplicated by: KAFKA-7763 KafkaProducer with transactionId endless waits when network is disconnection for 10-20s