Hi comsir, 采用 kafka 集群元数据 的 offset 信息和当前 group offset 相减得到的 lag 是比较准确的。 group id 需要自己维护。
comsir <609326...@qq.com.invalid> 于2021年7月20日周二 下午12:41写道： > hi all > 以kafka为source的flink任务，各位都是如何监控kafka的延迟情况？？ > 监控这个延迟的目的：1.大盘展示，2.延迟后报警 > 小问题： > 1.发现flink原生的相关metric指标很多，研究后都不是太准确，大家都用哪个指标？ > 2.怎么获取groupId呢，多个group消费的话，如何区分呀？ > 3.能通过kafka集群侧的元数据，和当前offset做减法，计算lag吗？ > 4.有比较优雅的实现方式吗？ > 非常感谢 期待解答 感谢感谢
