可以自己改一下源码中的消费者 判断偏移量 ,如果是原先的正常启动 如果不是则不进行启动

在 2020-06-22 20:09:11,"莫失莫忘" <xiaoxiong....@qq.com> 写道:
>如题,可以要求flink失败重启时 必须正常从checkpoint恢复,否则就重启失败吗?&nbsp;&nbsp;

回复