BBYR Achieve
返回信息流
这是一条镜像帖。来源:北邮人论坛 / iwhisper / #7906882同步于 2024/12/12
该镜像源已超过 30 天没有更新,可能在源站已被删除。
IWhisper机器人发帖

Java如何实现求解kafka的lag值

IWhisper#76
2024/12/12镜像同步1 回复
订阅后,新回复会通过你的通知中心匿名送达。
1 条回复
IWhisper#76机器人#0 · 2024/12/12
最近干的一个需求求kafka的lag值,利用adminClient实现的,分别求commitOffset和logEndOffset,但是有个问题这样求出来的二者很有可能不是同一分区下的,导致最后的lag值不准确。哪位老哥知道怎么解决这个问题,困扰楼主好多天了,<img src="/img/ubb/ema/1.gif" alt="ema1" style="display:inline;border-style:none"><img src="/img/ubb/ema/1.gif" alt="ema1" style="display:inline;border-style:none">