KafkaOffsetMonitor簡述
　　KafkaOffsetMonitor是有由Kafka開源社群提供的一款Web管理介面，這個應用程式用來實時監控Kafka服務的Consumer以及它們所在的Partition中的Offset，你可以通過瀏覽當前的消費者組，並且每個Topic的所有Partition的消費情況都可以觀看的一清二楚。它讓我們很直觀的知道，每個Partition的Message是否消費掉，有木有阻塞等等。

github下載地址
https://github.com/quantifind/KafkaOffsetMonitor

KafkaOffsetMonitor的安裝部署較為簡單，所有的資源都打包到一個JAR檔案中了，直接執行即可，新建一個監控目錄然後執行以下命令

[[email protected]] ~/kafka_monitor$ java -cp KafkaOffsetMonitor-assembly-0.2.1.jar \
> com.quantifind.kafka.offsetapp.OffsetGetterWeb \
> --zk 192.168.255.121:2181,192.168.255.122:2181,192.168.255.123:2181 \
> --port 8089 \
> --refresh 10.seconds \
> --retain 1.days
serving resources from: jar:file:/root/kafka_monitor/KafkaOffsetMonitor-assembly-0.2.1.jar!/offsetapp
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
log4j:WARN No appenders could be found for logger (org.I0Itec.zkclient.ZkConnection).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
2018-11-13 09:35:25.445:INFO:oejs.Server:jetty-7.x.y-SNAPSHOT
2018-11-13 09:35:25.524:INFO:oejsh.ContextHandler:started o.e.j.s.ServletContextHandler{/,jar:file:/root/kafka_monitor/KafkaOffsetMonitor-assembly-0.2.1.jar!/offsetapp}
2018-11-13 09:35:25.695:INFO:oejs.AbstractConnector:Started 
 
[email protected]:8089

web介面如下：192.168.255.121:8089

參考地址：
https://www.cnblogs.com/smartloli/p/4562551.html