【Kafka】Monitor - KafkaOffsetMonitor

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  ==> 數據保存週期
相關文章
相關標籤/搜索