[
https://issues.apache.org/jira/browse/KAFKA-6635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson reassigned KAFKA-6635:
--------------------------------------
Assignee: (was: Jason Gustafson)
> 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
> Priority: Major
>
> 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)
