在分布式架构下,部署了3个springboot服务,每个服务flink cdc connectors同步数据,如果每台服务器都向mysql发起同步请求就会存在两个问题:
1、数据重复
2、源数据库压力大
因为不想使用flink + flink cdc connectors的形式进行数据同步,想直接使用Java+flink cdc connectors jar包的形式完成日志请求、分析、加工及后续工作,但目前得到的资料大都是给予单个java + flink cdc connectors jar应用程序实现数据同步的案例,没有应用协调的案例。
请问有没有官方推荐或者业界标准的方法实现:多套java+ flink cdc connectors jar应用程序协调调用flink cdc connectors想数据库发起同步请求。