Kafka 的消费组 Offset 一目了然的监控工具,用起来还挺顺手的。KafkaOffsetMonitor的kafka-offset-monitor-assembly-0.4.6
这个版本,直接打包好了 Jar,部署也比较简单。
直接把 Jar 包丢到 Linux 服务器上,改一下start.sh
里的 Zookeeper 和 Kafka 地址,执行sh start.sh
就能跑起来。UI 虽然朴素点,但信息展示还蛮清晰,Topic、分区、消费组的 Offset 一览无遗,排查延迟、消费滞后的时候方便。
适合 Kafka 集群刚起步或者没接入大型监控系统的小团队。不需要复杂配置,也不用写脚本拉 Offset,对新手还蛮友好。实在不想折腾的话,这个工具就挺适合你。
如果你想看看源码原理,或者找点更进阶的玩法,下面这些文章可以挖掘下:
- Kafka Offset Monitor 0.4.6 Offset 监控工具
- KafkaOffsetMonitor 0.2.0 Kafka 消息偏移量监控工具
- Kafka 源码解析:生产消费模型深度解读
- Kafka 消费者群组与横向伸缩
如果你用 Flink、Kettle 搞流式,也可以配合看看,数据链路就更完整了。