upsert-kafka的时候不能设置group参数,那么在后续遇到问题的时候需要重启作业,就只能从头消费了,这个问题是不是应该设置checkpoint和savepoint来解决呢? https://help.aliyun.com/document_detail/444393.html?spm=a2c4g.414256.0.0.7460493ewif7QU
这个flink 问题是不是应该设置checkpoint和savepoint来解决呢?[阿里云实时计算 Flink版]
「点点赞赏,手留余香」
还没有人赞赏,快来当第一个赞赏的人吧!