weasker created KAFKA-7763:
------------------------------
Summary: KafkaProducer with transactionId endless waits when
network is disconnection
Key: KAFKA-7763
URL: https://issues.apache.org/jira/browse/KAFKA-7763
Project: Kafka
Issue Type: Bug
Components: clients, producer
Affects Versions: 2.1.0
Reporter: weasker
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...
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
