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
- duplicates
-
KAFKA-7887 Transaction Producer hanging when commiting/aborting transaction after a broker failure
-
- Closed
-
- relates to
-
KAFKA-7932 Streams needs to handle new Producer exceptions
-
- Resolved
-
- links to
