189 8069 5689
这篇文章将为大家详细讲解有关KafkaOffsetMonitor如何安装部署，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。
站在用户的角度思考问题，与客户深入沟通，找到马边彝族网站设计与马边彝族网站推广的解决方案，凭借多年的经验，让设计与互联网技术结合，创造个性化、用户体验好的作品，建站类型包括：成都网站设计、网站建设、企业官网、英文网站、手机端网站、网站推广、主机域名、网页空间、企业邮箱。业务覆盖马边彝族地区。
1.从标题都可以看出来，Kafka Offset Monitor，是对consumer消费情况进行监控,并能列出每 个consumer offset,滞后数据。
2.消费者组列表
3.每个topic的所有parition列表(topic,pid,offset,logSize,lag,owner)
4.查看topic的历史消费信息.
在安装KafkaOffsetMonitor管理平台时，我们需要先下载其安装包，其资源可以在Github上找到
KafkaOffsetMonitor的安装部署较为简单，所有的资源都打包到一个JAR文件中了，因此，直接运行即可，省去了我们去配置。这里我们可以新建一个目录单独用于Kafka的监控目录，我这里新建一个kafka_monitor文件目录，然后我们在准备启动脚本，脚本内容如下所示：
#! /bin/bash
java -cp KafkaOffsetMonitor-assembly-0.2.0.jar \
com.quantifind.kafka.offsetapp.OffsetGetterWeb \
--zk ZookeeperAddress \
--port 8089 \
--refresh 10.seconds \
--retain 1.days
给大家解释以下这条启动命令的含义，首先我们需要指明运行Web监控的类，然后需要用到ZooKeeper，所有要填写ZK集群信息，接着是Web运行端口，页面数据刷新的时间以及保留数据的时间值。
启动步骤如下所示：
步骤1:启动ZK zkServer.sh start
步骤2:启动Kafka服务（集群依次输入以下命令启动）
./kafka-server-start.sh config/server.properties &
步骤3:启动Web监控服务
java -cp KafkaOffsetMonitor-assembly-0.2.0.jar \
com.quantifind.kafka.offsetapp.OffsetGetterWeb \
--zk dn1:2181,dn2:2181,dn3:2181 \
--port 8089 \
--refresh 10.seconds \
--retain 1.days
Web服务启动成功后，如下图所示：
下面，我们来使用Kafka代码生产消费一些消息，使用Web监控来浏览消息情况。这里直接预览演示结果，如下图所示：
在运行KafkaOffsetMonitor的JAR包时，需要确保启动参数的配置正确，以免启动出错，另外，Github的上的KafkaOffsetMonitor的JAR中的静态资源有些链接用到了Google的超链接，所有如果直接只用，若本地木有代理软件会启动出错，这里使用我所提供的JAR，这个JAR是经过静态资源改版后重新编译的使用本地静态资源。
另外图中的一些参数的含义如下：
Topic：创建Topic名称
Partition：分区编号
Offset：表示该Parition已经消费了多少Message
LogSize：表示该Partition生产了多少Message
Lag：表示有多少条Message未被消费
Owner：表示消费者
Created：表示该Partition创建时间
Last Seen：表示消费状态刷新最新时间
关于“KafkaOffsetMonitor如何安装部署”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，使各位可以学到更多知识，如果觉得文章不错，请把它分享出去让更多的人看到。