回答1:应该通过 slot.name 为每个source 指定集群全局唯一的name ,此回答整理自钉群“Flink CDC 社区”