首页/数据/数据工程与 ETL 速查/kafka-consumer-groups.sh 列出消费组
本包目录(311 条)
管道基础52 条
Kafka64 条
调度与编排40 条数仓建模52 条数据质量50 条CDC 与同步53 条

kafka-consumer-groups.sh 列出消费组

列出全部消费组用于盘点与巡检:对比组清单可以发现废弃组与错连组,配合 describe 定位积压。

用途列出集群内的消费组
输出一行一个 group.id
巡检与基线清单对比,发现新增/消失的组

列出消费组

列出消费组
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list | wc -l
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list | grep '^order-'
组位移保存在 __consumer_offsets 主题;组列表在多租户集群中会较长,注意过滤与分页处理。

易错点

  • 无成员的组仍会出现在列表里(位移保留),不要仅凭列表判断链路存活
  • 删除组前确认没有历史位移与重放需求,否则重置位点会从零开始

数据来源与参考

  • Apache Kafka 官方文档:kafka-consumer-groups.sh
​‌‌​​‌​​​‌‌​‌‌‌‌​‌‌​​​‌‌​‌‌‌​​‌‌​​‌​‌‌‌​​‌‌‌​​​‌​‌‌​‌​​‌​‌‌‌​​​‌​‌‌​‌​​‌​‌‌​​​‌‌​‌‌‌​‌​​​‌‌​‌‌‌‌​​‌​‌‌‌​​‌‌​​​‌‌​‌‌​‌‌‌‌​‌‌​‌‌​‌