在Ubuntu上监控Kafka可采用以下方式:
# 查看所有Topic
kafka-topics.sh --list --bootstrap-server localhost:9092
# 查看Topic详情
kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic <topic_name>
# 列出消费者组
kafka-consumer-groups.sh --list --bootstrap-server localhost:9092
# 查看消费滞后(Lag)
kafka-consumer-groups.sh --describe --bootstrap-server localhost:9092 --group <group_id>
-Dcom.sun.management.jmxremote.port=9999
),再用jconsole
或VisualVM
连接端口查看指标。kafka-exporter
(通过Docker Compose),暴露Kafka指标给Prometheus。top/htop
监控CPU/内存占用,iostat
监控磁盘I/O,netstat
监控网络连接。/var/log/kafka
),排查异常信息。注:优先选择Prometheus+Grafana组合,兼顾实时性与可视化;小型集群可先用Kafka自带工具或Kafka Manager。
参考来源: