kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jason Gustafson (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-6635) Producer close does not await pending transaction
Date Sun, 11 Mar 2018 07:06:00 GMT
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)

Mime
View raw message