private void handleTimedOutRequests(List<ClientResponse> responses, long now) {
        List<String> nodeIds = this.inFlightRequests.nodesWithTimedOutRequests(now);
        for (String nodeId : nodeIds) {
            // close connection to the node
            this.selector.close(nodeId);
            log.info("Disconnecting from node {} due to request timeout.", nodeId);
            processTimeoutDisconnection(responses, nodeId, now);
        }
    }
Iterate over all the inflight requests and expire any requests that have exceeded the configured requestTimeout.
The connection to the node associated with the request will be terminated and will be treated as a disconnection.

@param responses The list of responses to update
@param now The current time
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java