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

Posted to dev@kafka.apache.org by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/04/09 20:04:00 UTC

[jira] [Created] (KAFKA-6768) Producer may hang in close with pending transaction

Jason Gustafson created KAFKA-6768:
--------------------------------------

             Summary: Producer may hang in close with pending transaction
                 Key: KAFKA-6768
                 URL: https://issues.apache.org/jira/browse/KAFKA-6768
             Project: Kafka
          Issue Type: Bug
          Components: producer 
    Affects Versions: 1.1.0
            Reporter: Jason Gustafson
            Assignee: Jason Gustafson
             Fix For: 1.1.1


There is an edge case for transactional producers which will cause close() to hang indefinitely (unless used with a timeout). Say, for example, that the producer is trying to send an AddPartitionsToTxn request to the broker. Upon shutdown, the Sender's running flag will be set to false and we will begin graceful shutdown. Graceful shutdown will not complete, however, until we can send the AddPartitionsToTxn request. But the latter is blocked by the fact that the running flag is disabled. So no progress can be made and shutdown cannot complete.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)