嘿，我来给你梳理几个实用的办法，帮你拿到Kafka消费者的消息消费速率（比如每秒多少条），都是日常运维和开发里常用的：

1. 用Kafka自带的命令行工具 #

Kafka提供了kafka-consumer-groups.sh（Windows环境是.bat脚本），能快速查看消费组状态，通过偏移量变化计算消费速率。

操作步骤： #

• 先执行命令获取当前消费组的偏移量：

  bin/kafka-consumer-groups.sh --bootstrap-server <你的Kafka broker地址>:9092 --describe --group <你的消费组名称>
  

  输出里的CURRENT-OFFSET字段就是当前消费到的位置。
• 隔一段时间（比如10秒）再执行一次同样的命令，拿到新的CURRENT-OFFSET。
• 计算速率：(新偏移量 - 旧偏移量) / 时间间隔，比如10秒内偏移量从10000涨到15000，那就是(15000-10000)/10 = 500条/秒。

这个方法适合快速排查，不需要额外工具支持。

2. 通过JMX监控实时速率 #

Kafka消费者会暴露JMX指标，其中就有直接的消费速率统计，非常适合长期监控场景。

关键指标： #

找到这个MBean路径下的records-consumed-rate指标：
kafka.consumer:type=consumer-fetch-manager-metrics,client-id=<你的消费者客户端ID>,topic=<目标主题>,partition=<分区ID>
这个指标直接代表每秒消费的消息条数，是实时计算的数值。

查看方式： #

• 用JConsole、VisualVM这类工具，直接连接消费者进程就能看到实时数值。
• 如果是集群部署，推荐用Prometheus采集这些JMX指标，再搭配Grafana做可视化面板，能直观看到速率的变化趋势。

3. 自定义代码统计（针对自研消费者） #

如果是你自己开发的消费者应用，可以直接在代码里加统计逻辑，灵活度最高。

比如Java消费者的示例：

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicLong;

// 定义原子计数器，保证多线程下计数准确
private final AtomicLong consumedRecordCount = new AtomicLong(0);

// 消费消息时累加计数
consumer.poll(Duration.ofMillis(100)).forEach(record -> {
    // 你的消息处理逻辑
    consumedRecordCount.incrementAndGet();
});

// 每秒统计并打印一次消费速率
ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();
scheduler.scheduleAtFixedRate(() -> {
    long count = consumedRecordCount.getAndSet(0);
    System.out.printf("当前消费速率：%d 条/秒%n", count);
}, 1, 1, TimeUnit.SECONDS);

如果用Spring Kafka这类框架，还可以借助Spring Boot Actuator暴露的metrics，直接通过/actuator/metrics/kafka.consumer.records.consumed.rate端点获取速率数据，不用自己写统计逻辑。

内容的提问来源于stack exchange，提问作者Rj1