1、下载kafkatool
下载地址Offset Explorer,下载对应系统的offset explorer
下载完,傻瓜安装即可(建议放D盘),在开始菜单输入offset找到该应用打开
打开
2、连接kafka
点击File > add new connection
Bootstrap servers可以输入单个节点,也可以输入一个集群,点击ping
点击Test,监听成功,点击是
3、查看消息内容以及消费者的offset
设置内容类型为String,方便查看
Tools > Settings
Topics -> 把Key和Value的内容格式都设置为String
选择想查看的topic,点击Properties,设置为String格式,点击Update即可
点击Data->绿色按钮,可以看到每一个消息的offset和value
点击其中一个消费者->Offsets,可以查看该消费者上一次提交的offset
从信息中可以看出
- 当前消费者组消费的主题是
test-topic
。 - 消费分区是
0
。 - 该分区中总共有 150 条消息(偏移量从
0
到149
)。 - 消费者组已经消费到第 90 条消息(
Offset = 90
)。 - 消费者组还有 60 条消息未消费(
Lag = 60
)。 - 最后一次偏移量提交的时间是
2024-11-17 01:40:11
。