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)