public void messageReceived(long bytes, long sendTimeNanos) {
        long latencyMicros = TimeUnit.NANOSECONDS.toMicros(StatsCollector.currentNanos() - sendTimeNanos);
        messagesReceived.increment();
        bytesReceived.add(bytes);
        endToEndLatencyMicros.recordValue(latencyMicros);
        totalMessagesReceived.increment();
        totalBytesReceived.add(bytes);
        totalEndToEndLatencyMicros.recordValue(latencyMicros);
        maxSendTimeNanos.updateAndGet(current -> Math.max(current, sendTimeNanos));
    }
The max send time of all messages received.
Used to determine whether any consumer catches up to a specific time.
tools/src/main/java/org/apache/kafka/tools/automq/perf/Stats.java