Re: Flink SQL Metrics中Kafka Offset请教

[JasonLee]

hi

currentOffsets: 表示的是每个分区的使用者当前读偏移量 , committedOffsets:
表示的是最后一次成功提交到Kafka的偏移量 ,因为 kafka 的 partition 的 offset 是从 0开始的 所以
committedOffsets 会比 currentOffsets 大 1



-----
Best Wishes
JasonLee
--
Sent from: http://apache-flink.147419.n8.nabble.com/