使用可视化工具kafkatool连接docker的kafka集群，查看消息内容和offset
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。
