You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

如何通过Prometheus监控Apache Kafka消费者组并在Grafana展示成员?

实现Grafana展示Kafka活跃消费者组及成员的方案

1. 部署Kafka Exporter

Kafka Exporter负责采集并暴露消费者组、成员相关的监控指标,需确保启动时开启对应采集开关:

  • 启动命令示例:
    ./kafka_exporter --kafka.server=kafka-broker:9092 --consumer.group.enabled --consumer.group.members.enabled
    
    其中--consumer.group.enabled开启消费者组指标采集,--consumer.group.members.enabled开启成员信息采集。

2. 配置Prometheus抓取指标

在Prometheus配置文件prometheus.yml中添加Kafka Exporter的抓取任务:

scrape_configs:
  - job_name: 'kafka_exporter'
    static_configs:
      - targets: ['kafka-exporter:9308'] # 替换为你的Kafka Exporter实际地址

修改完成后重启Prometheus使配置生效。

3. 在Grafana中创建展示面板

展示活跃消费者组列表

使用PromQL查询所有存在成员的消费者组:

count by (consumergroup) (kafka_consumergroup_member_info) > 0

选择「Table」面板类型,将consumergroup设为展示列,即可得到所有活跃消费者组列表。

展示消费者组成员详情

通过变量实现动态查看指定组的成员:

  1. 创建变量consumergroup,类型选择「Query」,查询语句填写label_values(kafka_consumergroup_member_info, consumergroup),支持下拉选择消费者组。
  2. 编写PromQL查询该组的成员信息:
kafka_consumergroup_member_info{consumergroup="$consumergroup"}

选择「Table」面板,展示member_id、client_id、client_host等标签字段,即可查看选中组的所有成员详情。

4. 注意事项

  • 确保使用v1.4.0及以上版本的Kafka Exporter,低版本可能不支持成员信息采集。
  • Kafka集群需开启group.metadata.enable(默认已开启),否则Exporter无法获取成员数据。

内容的提问来源于stack exchange,提问作者Магомед Якубов

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.07.25 01:57:06