Jason Gustafson created KAFKA-6768:
--------------------------------------
Summary: Producer may hang in close with pending transaction
Key: KAFKA-6768
URL: https://issues.apache.org/jira/browse/KAFKA-6768
Project: Kafka
Issue Type: Bug
Components: producer
Affects Versions: 1.1.0
Reporter: Jason Gustafson
Assignee: Jason Gustafson
Fix For: 1.1.1
There is an edge case for transactional producers which will cause close() to
hang indefinitely (unless used with a timeout). Say, for example, that the
producer is trying to send an AddPartitionsToTxn request to the broker. Upon
shutdown, the Sender's running flag will be set to false and we will begin
graceful shutdown. Graceful shutdown will not complete, however, until we can
send the AddPartitionsToTxn request. But the latter is blocked by the fact that
the running flag is disabled. So no progress can be made and shutdown cannot
complete.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
