Re: flink-1.14.0 chk提交kafka offset问题

[Guo Thompson]

应该是checkpoint的时候就会提交kafka 的offset

kcz <573693...@qq.com.invalid> 于2021年12月30日周四 14:54写道：

> 有一个问题请教下大佬们，学迷糊了，
> 用了flink-1.14.0版本，开启了chk(500ms做一次)，精准一次消费，事件时间
> source（kafka）-&gt; (1min的window，到时之后开始做count计算) -&gt; sink(mysql)
> 生产几条数据给kafka，但是没有超过窗口的1分钟触发时间，观察到了kafka偏移量被提交了。
> 最后的sink算子还没执行，kafka偏移量就被提交了，虽然chk已经做好了。
>
> 不是等sink执行之后，偏移量才被提交吗？