Jason Gustafson created KAFKA-6635:
--------------------------------------
Summary: Producer close does not await pending transaction
Key: KAFKA-6635
URL: https://issues.apache.org/jira/browse/KAFKA-6635
Project: Kafka
Issue Type: Bug
Components: producer
Reporter: Jason Gustafson
Assignee: Jason Gustafson
Currently close() only awaits completion of pending produce requests. If there
is a transaction ongoing, it may be dropped. For example, if one thread is
calling {{commitTransaction()}} and another calls {{close()}}, then the commit
may never happen even if the caller is willing to wait for it (by using a long
timeout). What's more, the thread blocking in {{commitTransaction()}} will be
stuck since the result will not be completed once the producer has shutdown.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
