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。
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。 |
