flinkcdc两个flink-sql同时运行,使用的是mysql-cdc表,日志显示发生了server id冲突:
Caused by: io.debezium.DebeziumException: A slave with the same server_uuid/server_id as this slave has connected to the master...
Error code: 1236; SQLSTATE: HY000.
The 'server-id' in the mysql cdc connector should be globally unique, but conflicts happen now.
关于server id冲突,想请教一下大家:
1:不同mysql集群之间,server id可以相同?
2:同一个mysql-master,不同flink-sql中使用同一个mysql-cdc表,每个表的server id不能相同?
3:同一个mysql-master,同一个flink-sql中多个地方使用同一个mysql-cdc表,每次使用这个表的server id不能相同?
4:同一个mysql-master,同一个flink-sql中使用多个不同的mysql-cdc表,每个表的server id不能相同?
5:官方文档说server id默认取值范围是 5400 -- 6400 ,那我使用超过6400+的server id,会不会有问题?
1、不同mysql集群之间,server id可以相同,
2、如果是不同的链接,flink-sql,每个表的server id不能相同,如果是同一个source,server id一个就行了(整库同步)
3、官方文档说server id默认取值范围是 5400 -- 6400 ,那我使用超过6400+的server id,不会有问题
4、推荐使用整库同步,(3.0的pipeline)此回答来自钉群Flink CDC 社区。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。