在Linux系统中监控Kafka可采用以下方式：

一、使用Kafka自带工具

• 命令行工具：
  • kafka-topics.sh：查看主题详情（如分区、副本）。
  • kafka-consumer-groups.sh：监控消费者组状态、消费进度及滞后情况。
  • kafka-run-class.sh：运行性能测试工具（如ProducerPerformance、ConsumerPerformance）。
• JMX监控：
  • 通过jconsole或kafka-run-class.sh kafka.tools.JmxTool连接Kafka的JMX端口，查看吞吐量、延迟等指标。

二、第三方监控工具

• Prometheus + Grafana：
  • 部署kafka-exporter暴露Kafka指标，Prometheus抓取数据，Grafana可视化展示（如消息堆积、消费速率）。
• Kafka Manager（CMAK）：
  • 提供集群状态、主题/分区管理及消费者监控的Web界面。
• Burrow：
  • 专注监控消费者偏移量，支持告警配置。
• Confluent Control Center：
  • 官方商业工具，支持集中化监控、性能分析和报警。

三、日志与系统监控

• 查看Kafka日志：
  • 通过tail -f /var/log/kafka/server.log实时监控服务日志。
• 系统资源监控：
  • 使用top、htop或ps命令查看Kafka进程的CPU、内存占用。

四、自定义监控

• 编写脚本调用Kafka Java客户端API，抓取指标并触发报警（如消息堆积超过阈值时发送通知）。

工具选择建议：

• 简单场景：jconsole + 自带命令行工具。
• 复杂集群：Prometheus + Grafana + Kafka Manager。
• 企业级需求：Confluent Control Center。

参考资料：