是可以这样恢复。 但是如果使用setStartFromGroupOffsets() 如果中间程序挂了， 会导致消费者已经提交了offset，但是下游数据没有处理完 ，或者没有sink到下游 下次重启会从kakfa的偏移量开始消费 没有处理的数据，会丢失
在 2021-01-18 10:50:44，"hoose" <307840...@qq.com> 写道： >我理解的是这样，虽然不是从savepoint里恢复，但kafka >consumer_topic有了我们之前保存的groupid,那么默认的是flink是这样设置： > >setStartFromGroupOffsets()：默认值，从当前消费组记录的偏移量开始，接着上次的偏移量消费 > >这样可以理解还是从上次提交的offset开始继续消费对吧？ > > > >-- >Sent from: http://apache-flink.147419.n8.nabble.com/
