flink 消费2个kafka topic a,b,状态成功保存在savepoint,
途中删掉一个topic a,运行一会再把这个topic a加回来,
这时候这个topic a 的状态就无法读取了 会重新消费, 但是偏移量是还保存在kafka _consumer_offsets 里面,有没有办法能让他继续从之前的offset 消费呢?
flink 有没有办法能让他继续从之前的offset 消费呢?[阿里云实时计算 Flink版]
「点点赞赏,手留余香」
还没有人赞赏,快来当第一个赞赏的人吧!