Hi！ 这里的 offset 是 kafka source 的 offset 吗？其实没必要通过 checkpoint 读取 offset，可以通过 metrics 读取，见 [1]。
[1] https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/metrics/#kafka-connectors 杨浩 <[email protected]> 于2021年10月25日周一 上午10:20写道： > 请问下，如果启用checkpoint，因为状态比较大，checkpoint间隔设置比较大，如何让offset提交的比较快，这样方便监控程序进度
