[
https://issues.apache.org/jira/browse/KAFKA-6635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818449#comment-16818449
]
ASF GitHub Bot commented on KAFKA-6635:
---------------------------------------
hachikuji commented on pull request #5971: KAFKA-6635: Producer close awaits
for pending transaction
URL: https://github.com/apache/kafka/pull/5971
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> 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
>
> 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)
