我的意思 是不使用checkpoint。 使用'scan.startup.mode' = 'group-offsets' 去维护offset
在 2021-01-15 11:35:16,"Michael Ran" <greemqq...@163.com> 写道: >下游sink还没有完成, offset 不是在checkpoint 里面的吗?<br/>下次启动会从你ck的位置恢复才对。<br/>除非你sink >是异步操作,告诉上游你sink 完成了,实际你sink失败了 >在 2021-01-15 10:29:15,"air23" <wangfei23_...@163.com> 写道: >>flink消费kafka 只能使用checkpoint去维护offset吗 >> >>我这边使用'scan.startup.mode' = 'group-offsets' >> >>如果中间报错了 或者停止任务,但是我下游sink还没有完成, >>下次启动直接跳过这个报错的数据,会丢数据,谢谢回复