项目中的kafka需要做监控,以及topic的的写入消费数offsize,未消费数log,找遍了各种资料,没有找到获取offsize的途径,这样放才能获取topic未消费量。 kafka版本2.11-1.1.0,望大佬抽出宝贵的时间指点一二,最好能有代码。
文档:Kafka获取lag.note
链接:https://note.youdao.com/noteshare?id=eb92186b5e03b5dcf605c92545fc5749
先看看这个,布局有点乱,我回头要在整理一下。
https://www.orchome.com/49
你的答案