使用可视化工具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。