计算kafka消费组Lag最佳实践最新版
之前写过一篇如何监控 kafka 消费 Lag 情况,五年前写的,在 google 上访问量很大,最近正好需要再写这个功能,就查看了最新 API,发现从2.5.0
版本后新增了listOffsets
方法,让计算 Lag 更简单方便和安全,代码量有质的下降,因为舍弃一些功能,代码精简的了很多。
实践
这里我用最新版做演示,在 pom 文件中增加依赖
1 | <dependency> |
首先初始化 AdminClient
1 | Properties config = new Properties(); |
然后根据 topic 和 groupId 计算 Lag,这种方案要比之前方式优雅了很多。