根据网上的操作,自己又总结了一下。
首先下载kafkaoffsetmonitor编译好的jar包,可以选择官方版,也可以选择修改版,据说修改版解决了卡顿的问题,我数据量小,没体会出来。你们可以自行解决。我也是用编译好的包,据说可以自行编译,我嫌麻烦。
下载好之后就上传到服务器,随便建一个文件夹
cd /usr/local
mkdir kafkaoffsetmonitor
cd kafkaoffsetmonitor
mv /home/download/KafkaOffsetMonitor-assembly-..jar /usr/local/kafkaoffsetmonitor
然后需要编写一个启动的shell脚本
vim kafkaoffset.sh
#输入以下内容
java -cp KafkaOffsetMonitor-assembly-.jar \
com.quantifind.kafka.offsetapp.OffsetGetterWeb \
--zk :,:,: \
--port \
--refresh seconds \
--retain days
解释一下:
–zk:你的zookeeper的地址和端口
–port:本地查看UI的端口
–refresh:刷新时间
–retain:数据保留时间
既然指定了zk端口和本地端口,也就意味着你的这个监控并不需要跑在kafka同一个服务器上面,任何一台机器都可以跑起来,只要指定好zk就好,我也是经过实践了的,在本地跑起来了
然后两者给予权限:
chmod kafkaoffset.sh
chmod KafkaOffsetMonitor-assembly-..jar
然后执行即可,先前台执行,如果没问题,就可以关闭之后用后台启动。如果关闭终端程序就退出了,所以先确保没问题,再切换到后台。
#前台启动查看是否正常,浏览器输入“ip:port”,比如我的是“222.30.194.254:2551”,如果页面正常显示,即正常启动
sh kafkaoffset.sh
#没问题就可以后台启动了
nohup sh kafkaoffset.sh >/dev/null >& &
然后就可以查看了,界面还是很一目了然的。纪录到此结束。
感谢万能的网友和伟大的GIT。