1. 程式人生 > >Kafka的web 監控平臺

Kafka的web 監控平臺

1. 下載KafkaOffsetMonitor-assembly-0.2.0.jar 

2. 建立/data/server/flink-web-monitor目錄,將jar包放在該目錄下,同時建立kafkacom.sh指令碼:

-Xms128M -Xmx256M -Xss1024K -XX:PermSize=128m -XX:MaxPermSize=256m -cp ./KafkaOffsetMonitor-assembly-0.2.0.jar com.quantifind.kafka.offsetapp.OffsetGetterWeb --zk localhost:2181 --port 8086 --refresh 10.seconds --retain 7.days 1> kakfa.offset.monitor.logs.stdout.log 2>kafka.offset.monitor.logs.stderr.log &

3. 啟動zookeeper與kafka集群后,執行kafkacom.sh指令碼

4. 訪問10.8.45.10:8086,就可以看到相關的monitor 監控頁面,可以看每個group 下的topic 的消費情況