Re: 回复：flink怎么读kafka offset

[hoose]

我理解的是这样，虽然不是从savepoint里恢复，但kafka
consumer_topic有了我们之前保存的groupid,那么默认的是flink是这样设置：

setStartFromGroupOffsets()：默认值，从当前消费组记录的偏移量开始，接着上次的偏移量消费

这样可以理解还是从上次提交的offset开始继续消费对吧？



--
Sent from: http://apache-flink.147419.n8.nabble.com/