kafka监控

下载地址

源码地址：https://github.com/danielqsj/kafka_exporter
镜像地址：https://hub.docker.com/r/danielqsj/kafka-exporter/tags
板子地址：https://grafana.com/grafana/dashboards/7589-kafka-exporter-overview/

启动

docker run -ti --rm -p 9308:9308 danielqsj/kafka-exporter --kafka.server=kafka:9092 [--kafka.server=another-server ...]

监控项

Kafka 运行时间：
up{instance="$instance"}

Broker 数量：
kafka_brokers{instance="$instance"}

Topic 分区数：
sum by(topic) (kafka_topic_partitions{instance="$instance",topic=~"$topic"})

每秒消费完成的次数 (CURRENT-OFFSET)：
sum(rate(kafka_topic_partition_current_offset{instance="$instance", topic=~"$topic"}[$time])) by (topic)

当前队列消费堆积数量  (LAG)：
sum(kafka_consumergroup_lag{instance="$instance",topic=~"$topic"}) by (consumergroup, topic)