@Override
    public boolean hasInFlightRequests(String node) {
        return !this.inFlightRequests.isEmpty(node);
    }
Get the number of in-flight requests for a given node
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java