[ https://issues.apache.org/jira/browse/KAFKA-6635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jason Gustafson updated KAFKA-6635: ----------------------------------- Fix Version/s: 2.3.0 > 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: Viktor Somogyi-Vass > Priority: Major > Fix For: 2.3.0 > > > 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)