KafkaOffsetMonitor topic消费监控

KafkaOffsetMonitor简述
  KafkaOffsetMonitor是有由Kafka开源社区提供的一款Web管理界面,这个应用程序用来实时监控Kafka服务的Consumer以及它们所在的Partition中的Offset,你可以通过浏览当前的消费者组,并且每个Topic的所有Partition的消费情况都可以观看的一清二楚。它让我们很直观的知道,每个Partition的Message是否消费掉,有木有阻塞等等。

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

KafkaOffsetMonitor的安装部署较为简单,所有的资源都打包到一个JAR文件中了,直接运行即可,新建一个监控目录然后运行以下命令

[root@slave1] ~/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

猜你喜欢

转载自blog.csdn.net/fanren224/article/details/84037787