最新的Flink CDC连接器是基于flink1.7,在1.8环境下可用吗?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
Flink CDC连接器是Apache Flink的源连接器,主要用于提取不同数据库的更改数据。Flink社区开发的flink-cdc-connectors组件可以直接从MySQL、PostgreSQL等数据库读取全量数据和增量变更数据。其版本与Flink的版本有一定的独立性,但在集成时仍需要注意版本匹配的问题。
对于你的问题,关于在Flink 1.8环境下使用基于flink 1.7版本的Flink CDC连接器,这主要取决于两个因素:连接器本身是否支持Flink 1.8,以及你的项目是否能够兼容这个版本的连接器。具体来说,你需要从maven仓库下载对应版本的cdc jar文件,并放到Flink安装包解压之后的lib目录。同时,需要注意的是,快照版本需要用户下载源代码并编译相应的jar,而用户应优先考虑使用已经发布的版本。
Flink CDC连接器是专为Apache Flink设计的源连接器,它通过使用变更数据捕获(CDC)从不同的数据库中摄取变化。这个连接器集成了Debezium作为其引擎来捕捉数据更改。根据Flink CDC的版本映射,Flink CDC 2.3.x确实支持Flink 1.8版本。因此,基于flink 1.8的环境是可以使用最新的Flink CDC连接器的。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。