现在flink cdc connectors能够集群部署吗?一共部署了3个相同的springboot服务,集成的flinkcdc功能,这时候会抽取三份相同的数据往下游发?求解答
Flink CDC Connectors 目前不支持集群部署,但可以通过一些方法实现类似集群部署的效果。
一种方法是使用 Flink CDC Connectors 的本地模式,在本地启动多个 Flink 作业,每个作业连接一个 Spring Boot 应用。这种方法比较简单,但需要在每个 Flink 作业中配置不同的连接参数,并且每个 Flink 作业都需要运行在一个单独的 JVM 进程中。
另一种方法是使用 Flink CDC Connectors 的集群模式,在 Flink 集群中启动一个 Flink 作业,该作业连接多个 Spring Boot 应用。这种方法可以实现更高的可靠性和可伸缩性,但需要在 Flink 集群中配置多个 Kafka 主题,并且需要在 Flink 作业中使用 Flink CDC Connectors 的集群模式。
总体而言,Flink CDC Connectors 的集群部署是一个比较复杂的问题,需要根据具体的使用场景来选择合适的方法。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。