本篇文章主要是介紹kafkaoffsetmonitor的配置步驟java
1、下載kafkaoffsetmonitor的jar包,能夠到github搜索kafkaoffsetmonitor,第一個就是,裏面能夠下載編譯好了的包。KafkaOffsetMonitor-assembly-0.2.1.jargit
wget https://github.com/quantifind/KafkaOffsetMonitor/releases/download/v0.2.1/KafkaOffsetMonitor-assembly-0.2.1.jar
2、新建在kafka的bin下面新建kafka-monitor文件夾,把jar包KafkaOffsetMonitor-assembly-0.2.1.jar丟進去,而且在文件夾裏新建腳本文件kafka-monitor,文件內容以下:github
#!/bin/bash java -cp KafkaOffsetMonitor-assembly-0.2.1.jar \ com.quantifind.kafka.offsetapp.OffsetGetterWeb \ --zk 127.0.0.1:2181 \ --port 8089 \ --refresh 10.seconds \ --retain 1.days #127.0.0.1:2181 爲zookeeper的地址和端口(根據環境修改) #8089爲生成的服務的端口號(根據環境修改)
3、啓動kafka以後,而後在運行kafka-monitor文件瀏覽器
source ~/.bashrc nohup ./kafka-monitor &
四、在瀏覽器中便可使用ip:8089訪問kafka的監控頁面。bash