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

Posted to jira@kafka.apache.org by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2020/05/21 08:53:00 UTC

[jira] [Created] (KAFKA-10029) Selector.completedReceives should not be modified when channel is closed

Rajini Sivaram created KAFKA-10029:
--------------------------------------

             Summary: Selector.completedReceives should not be modified when channel is closed
                 Key: KAFKA-10029
                 URL: https://issues.apache.org/jira/browse/KAFKA-10029
             Project: Kafka
          Issue Type: Bug
          Components: network
    Affects Versions: 2.5.0
            Reporter: Rajini Sivaram
            Assignee: Rajini Sivaram
             Fix For: 2.6.0, 2.5.1


Selector.completedReceives are processed using `forEach` by SocketServer and NetworkClient when processing receives from a poll. Since we may close channels while processing receives, changes to the map while closing channels can result in ConcurrentModificationException. We clear the entire map after each poll anyway, so we don't need to remove channel from the map while closing channels.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)