回复：flink1.9.1 在WebUI中查看committedOffsets指标为负值

[JasonLee <17...@163.com>]

hi
提交offset到Kafka是在ck成功之后 如果没有开启ck的话 需要设置自动提交提交offset


| |
JasonLee
|
|
邮箱：17610775726@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/

Re: flink1.9.1 在WebUI中查看committedOffsets指标为负值

[bradyMk <zh...@126.com>]

好的，我去看一下，感谢您的解答~



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

Re: flink1.9.1 在WebUI中查看committedOffsets指标为负值

[shizk233 <wa...@gmail.com>]

如JasonLee所说，你可以在FlinkKafkaConsumerBase的notifyCheckpointComplete方法中看到提交offset的逻辑。
值得注意的是，此处的chk完成指的是整个链路上的chk完成，而不是kafka source的chk完成。


JasonLee <17...@163.com> 于2020年7月30日周四 下午9:59写道：

> hi
> 提交offset到Kafka是在ck成功之后 如果没有开启ck的话 需要设置自动提交提交offset
>
>
> | |
> JasonLee
> |
> |
> 邮箱：17610775726@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/