You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2019/04/15 22:57:00 UTC

[jira] [Updated] (KAFKA-6635) Producer close does not await pending transaction

     [ 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)