【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  ==> 数据保存周期
相关文章
相关标签/搜索