1、下載java
https://github.com/quantifind/KafkaOffsetMonitor/releases/ git
[root@hftest0001 KafkaOffsetMonitor]# pwd /opt/KafkaOffsetMonitor [root@hftest0001 KafkaOffsetMonitor]# ll total 51980 -rw------- 1 root root 53221516 Jan 28 13:39 KafkaOffsetMonitor-assembly-0.2.0.jar [root@hftest0001 KafkaOffsetMonitor]#
2、啓動github
[root@hftest0001 KafkaOffsetMonitor]# pwd /opt/KafkaOffsetMonitor [root@hftest0001 KafkaOffsetMonitor]# cat monitor_start.sh #!/bin/bash java -Xms512M -Xmx512M -Xss1024K -XX:PermSize=256m -XX:MaxPermSize=512m -cp KafkaOffsetMonitor-assembly-0.2.0.jar com.quantifind.kafka.offsetapp.OffsetGetterWeb --zk 10.224.246.155:2181,10.224.246.154:2181,10.224.246.201:2181 --port 8080 --refresh 10.seconds --retain 1.days 1>monitor.stdout.log 2>monitor.stderr.log & --zk ==> kafka集羣的zookeeper地址 --port ==> kafka offset monitor啓動後監聽的http端口 --refresh ==> 刷新數據 --retain ==> 數據保存週期