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

[Ada Wong]

你说的偏移量提交是指提交给Kafka Broker当前group的offset？

Guo Thompson <gwqloveli...@gmail.com> 于2021年12月30日周四 15:36写道：
>
> 应该是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执行之后，偏移量才被提交吗？