问题1:Flink CDC2.4.0连接pgsql的source任务停止后再启动一直提示复制槽重复,有什么配置能解决吗? 问题2:指定的是全局唯一的,如果source并行度大于1,第二个source创建连接的时候就提示复制槽已存在;如果source并行度为1,则下次重启的时候也会提示复制槽已存在
Flink CDC2.4.0连接pgsql的source任务停止后再启动一直提示复制槽重复,有什么?[阿里云实时计算 Flink版]
「点点赞赏,手留余香」
还没有人赞赏,快来当第一个赞赏的人吧!
回答1:应该通过 slot.name 为每个source 指定集群全局唯一的name ,此回答整理自钉群“Flink CDC 社区”