如何获取消费指定Kafka Topic的同一消费组客户端总数？

你的理解基本正确，补充一个关键细节：Kafka的分区分配具体规则由配置的partition.assignment.strategy（默认是Range+CooperativeSticky策略）决定，但核心原则始终不变：

• 同一消费组内，一个分区只能被一个消费者实例消费
• 当分区数量多于消费组内的消费者数量时，会有部分消费者被分配到多个分区（就像你例子里的第3个分区会分给A/B/C中的某一个）

可以使用Kafka自带的命令行工具kafka-consumer-groups.sh（Windows环境用kafka-consumer-groups.bat）实现，具体操作如下：

1. 查看消费组完整信息（包含在线消费者数） #

执行命令查看消费组的详细状态，其中会明确列出活跃消费者数量：

kafka-consumer-groups.sh --bootstrap-server <你的Kafka Broker地址> --describe --group <消费组名称>

对应你例子中的场景，命令为：

kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group shipping

输出结果中CONSUMER-ID列的条目数，就是当前在线的客户端总数。

2. 直接提取在线客户端数量 #

如果只想快速得到数字，可以结合文本处理工具过滤结果：

kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group shipping | grep "ACTIVE" | wc -l

说明：该命令会过滤出消费组内的活跃消费者条目，统计行数即为在线客户端总数。

注意：上述命令仅统计在线活跃的客户端；若需统计消费组内曾注册过的所有客户端（含离线），可查看输出中members相关的完整列表，但业务场景中通常更关注在线活跃的消费者数量。

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