请问有办法和现有监控兼容么？开启checkpoint时，让消费组的offset实时更新
在 2021-10-25 21:58:28，"杨浩" <yangha...@163.com> 写道：
>currentOffsets理论上OK，但是这边云上监控系统中的kafka未消费量使用的是committedOffsets
>在 2021-10-25 10:31:12，"Caizhi Weng" <tsreape...@gmail.com> 写道：
>>Hi！
>>
>>这里的 offset 是 kafka source 的 offset 吗？其实没必要通过 checkpoint 读取 offset，可以通过
>>metrics 读取，见 [1]。
>>
>>[1]
>>https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/metrics/#kafka-connectors
>>
>>杨浩 <yangha...@163.com> 于2021年10月25日周一 上午10:20写道：
>>
>>> 请问下，如果启用checkpoint，因为状态比较大，checkpoint间隔设置比较大，如何让offset提交的比较快，这样方便监控程序进度
