如JasonLee所说，你可以在FlinkKafkaConsumerBase的notifyCheckpointComplete方法中看到提交offset的逻辑。 值得注意的是，此处的chk完成指的是整个链路上的chk完成，而不是kafka source的chk完成。
JasonLee <[email protected]> 于2020年7月30日周四 下午9:59写道： > hi > 提交offset到Kafka是在ck成功之后 如果没有开启ck的话 需要设置自动提交提交offset > > > | | > JasonLee > | > | > 邮箱：[email protected] > | > > Signature is customized by Netease Mail Master > > 在2020年07月30日 19:37，bradyMk 写道： > 谢谢解答~ > > 这个确实是个不变的值，应该是没有成功提交；而且我发现了，只要是没有设置ck的任务，该指标都会显示这个值，如果设置了ck，就会正常；但是我不懂为什么会这样，请问您知道详细的原因么？ > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/
