Cameron created KAFKA-7887:
------------------------------
Summary: Transaction Producer hanging when commiting/aborting
transaction after a broker failure
Key: KAFKA-7887
URL: https://issues.apache.org/jira/browse/KAFKA-7887
Project: Kafka
Issue Type: Bug
Components: clients
Affects Versions: 2.0.1
Reporter: Cameron
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
{code:java}
while(!completed) {
try {
this.latch.await();
completed = true;
} catch (InterruptedException var3) {
}
}
{code}
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
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
