void incrementThrottleTime(String nodeId, long throttleTimeMs) {
        requests.getOrDefault(nodeId, new ArrayDeque<>()).
                forEach(request -> request.incrementThrottleTime(throttleTimeMs));
    }
Returns a list of nodes with pending in-flight request, that need to be timed out

@param now current time in milliseconds
@return list of nodes
clients/src/main/java/org/apache/kafka/clients/InFlightRequests.java