开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

请问flinkcdc中Postgresql CDC 会自动同步表结构变更(DDL)吗?

请问flinkcdc中Postgresql CDC 会自动同步表结构变更(DDL)吗?

展开
收起
十一0204 2023-07-19 17:13:00 112 0
2 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    是的,Flink CDC 官方提供了一些示例代码,您可以参考这些示例代码了解如何使用 Flink CDC。以下是一些常见的示例代码:

    Debezium MySQL CDC 示例
    Flink CDC 提供了一个基于 Debezium MySQL CDC 连接器的示例,可以捕获来自 MySQL 数据库的变更事件,并将其写入 Apache Kafka 主题。该示例代码位于 flink-cdc-examples/flink-cdc-debezium-mysql-kafka 目录下。

    Oracle CDC 示例
    Flink CDC 还提供了一个基于 Oracle CDC 的示例,可以捕获来自 Oracle 数据库的变更事件,并将其写入 Apache Kafka 主题。该示例代码位于 flink-cdc-examples/flink-cdc-oracle-kafka 目录下。

    MySQL CDC 示例
    Flink CDC 还提供了一个基于 MySQL CDC 的示例,可以捕获来自 MySQL 数据库的变更事件,并将其写入 Apache Kafka 主题。该示例代码位于 flink-cdc-examples/flink-cdc-mysql-kafka 目录下。

    2023-07-29 20:16:26
    赞同 展开评论 打赏
  • 意中人就是我呀!

    includeSchemaChanges。此回答整理至钉群“Flink CDC 社区”。

    2023-07-19 17:38:34
    赞同 展开评论 打赏

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

相关电子书

更多
云栖大会:开源 PolarDB 架构演进、关键技术与社区建设 立即下载
2023云栖大会:和客户一起玩转PolarDB新特性 立即下载
2023云栖大会:PolarDB for AI 立即下载

相关镜像