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

Posted to dev@kafka.apache.org by "Manikumar (JIRA)" <ji...@apache.org> on 2019/03/07 09:36:00 UTC

[jira] [Created] (KAFKA-8061) Use forceClose flag to check in the loop inside maybeWaitForProducerId.

Manikumar created KAFKA-8061:
--------------------------------

             Summary: Use forceClose flag to check in the loop inside maybeWaitForProducerId.
                 Key: KAFKA-8061
                 URL: https://issues.apache.org/jira/browse/KAFKA-8061
             Project: Kafka
          Issue Type: Bug
    Affects Versions: 2.1.1
            Reporter: Manikumar
            Assignee: Manikumar


In KAFKA-5503, we have added a check (https://github.com/apache/kafka/pull/5881) for `running` flag in the loop inside maybeWaitForProducerId.  This is to avoid blocking sender thread shutdown call, while we attempt to get the ProducerId.

This created a corner case where sender thread gets blocked, if we had concurrent producerId reset and shutdown call. The proposed fix is to check the forceClose flag in the loop inside maybeWaitForProducerId.

 

 



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