最新的Flink CDC连接器是基于flink1.7,在1.8环境下可用吗?

最新的Flink CDC连接器是基于flink1.7,在1.8环境下可用吗?

展开
收起
真的很搞笑 2023-12-05 20:45:30 134 分享 版权
3 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    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,而用户应优先考虑使用已经发布的版本。

    2023-12-06 14:27:49
    赞同 展开评论
  • 目前还不行哈,等新版 ,此回答整理自钉群“Flink CDC 社区”

    2023-12-06 13:32:58
    赞同 展开评论
  • Flink CDC连接器是专为Apache Flink设计的源连接器,它通过使用变更数据捕获(CDC)从不同的数据库中摄取变化。这个连接器集成了Debezium作为其引擎来捕捉数据更改。根据Flink CDC的版本映射,Flink CDC 2.3.x确实支持Flink 1.8版本。因此,基于flink 1.8的环境是可以使用最新的Flink CDC连接器的。

    2023-12-06 09:01:38
    赞同 展开评论

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

还有其他疑问?
咨询AI助理