Re: Flink SQL Metrics中Kafka Offset请教

Sun, 25 Apr 2021 04:30:32 -0700 

非常感谢！

> 在 2021年4月25日，19:19，JasonLee <[email protected]> 写道：
> 
> hi
> 
> currentOffsets: 表示的是每个分区的使用者当前读偏移量 , committedOffsets:
> 表示的是最后一次成功提交到Kafka的偏移量 ,因为 kafka 的 partition 的 offset 是从 0开始的 所以
> committedOffsets 会比 currentOffsets 大 1
> 
> 
> 
> -----
> Best Wishes
> JasonLee
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/

回复