private void handleDisconnections(List<ClientResponse> responses, long now) {
        for (Map.Entry<String, ChannelState> entry : this.selector.disconnected().entrySet()) {
            String node = entry.getKey();
            ChannelState channelState = entry.getValue();
            if (channelState == ChannelState.EXPIRED) {
                log.debug("Idle connection to node {} disconnected.", node);
            } else {
                log.info("Node {} disconnected.", node);
            }
            processDisconnection(responses, node, now, channelState);
        }
    }
Handle any disconnected connections

@param responses The list of responses that completed with the disconnection
@param now The current time
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java