千家信息网

KafkaOffsetMonitor如何安装部署

发表于:2025-12-03 作者:千家信息网编辑
千家信息网最后更新 2025年12月03日,这篇文章将为大家详细讲解有关KafkaOffsetMonitor如何安装部署,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。KafkaOffsetMonitor功能:
千家信息网最后更新 2025年12月03日KafkaOffsetMonitor如何安装部署

这篇文章将为大家详细讲解有关KafkaOffsetMonitor如何安装部署,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。

KafkaOffsetMonitor功能:

1.从标题都可以看出来,Kafka Offset Monitor,是对consumer消费情况进行监控,并能列出每 个consumer offset,滞后数据。

2.消费者组列表

3.每个topic的所有parition列表(topic,pid,offset,logSize,lag,owner)

4.查看topic的历史消费信息.

1下载

  在安装KafkaOffsetMonitor管理平台时,我们需要先下载其安装包,其资源可以在Github上找到

2安装部署

  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运行端口,页面数据刷新的时间以及保留数据的时间值。

3、启动

  启动步骤如下所示:

  • 步骤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服务启动成功后,如下图所示:

4.KafkaOffsetMonitor运行预览

  下面,我们来使用Kafka代码生产消费一些消息,使用Web监控来浏览消息情况。这里直接预览演示结果,如下图所示:

5.总结

  在运行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如何安装部署"这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,使各位可以学到更多知识,如果觉得文章不错,请把它分享出去让更多的人看到。

消费 资源 监控 运行 时间 步骤 数据 目录 篇文章 静态 服务 信息 内容 参数 含义 命令 情况 文件 更多 消息 数据库的安全要保护哪些东西 数据库安全各自的含义是什么 生产安全数据库录入 数据库的安全性及管理 数据库安全策略包含哪些 海淀数据库安全审计系统 建立农村房屋安全信息数据库 易用的数据库客户端支持安全管理 连接数据库失败ssl安全错误 数据库的锁怎样保障安全 中云智控深圳软件开发有限公司 模拟器如何选择服务器 数据库建表基本操作实验内容 xcode 使用自带数据库 云服务器桌面显示不出来 国家网络安全宣传时间 大专计算机网络技术招生院校 广州汽车软件开发联系方式 大学校园网络安全调查问卷 掌上东航软件开发公司 怎么比较xrd数据库 亚马逊服务器怎么建 电脑如何通过网络存储在服务器 创造与魔法2022年最新服务器 英文数据库与英语文献检索 吕梁软件开发app 网络安全协同设计方案 字符型数字导入数据库 数据库业绩实时排名如何做 数据库查询每个班成绩前三的同学 网络安全原理与应用实验报告 软件开发能力排行榜 工厂ERP编程软件开发 web服务器运维管理试题 上海亦恺互联网科技有限公司介绍 计算机网络技术串讲 虹口区会计网络技术供应商家 江西企业软件开发哪家好 部队网络安全教育讨论交流 嘉定区现代化网络技术试验设备
0