public void onSendAttempt(final long currentTimeMs) {
        this.requestInFlight = true;

        // Here we update the timer everytime we try to send a request.
        this.lastSentMs = currentTimeMs;
    }
@return True if no response has been received after the last send, indicating that there
is a request in-flight.
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestState.java