Kafka的web 監控平臺
阿新 • • 發佈:2019-02-18
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 的消費情況