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)