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