在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。
参考来源: