通常Kafka的监控我们采用KafkaOffsetMonitor,相关下载链接请参见:http://blog.csdn.net/lizhitao/article/details/27199863
安装布署完成后通过如下命令来启动监控:
1 | nohup java -cp KafkaOffsetMonitor-assembly-0.2.1.jar com.quantifind.kafka.offsetapp.OffsetGetterWeb -zk XXX:yyy,TTT:zzz --port 9090 --refresh 10.seconds --retain 5.days & |
可以通过http://IP:9090或者http://DNS:9090来访问
其中Consumer Offsets表各个列的含义如下:
注意:刚开始启动时,发现Lag为负数,这明显不对,但是当使用Producer和Consumer进行读写Kafka后,数字显示正常
联系客服