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

请问一下各位大佬,我用flink cdc2.3连接mysql,用的java进程连接的,连接rds ?

请问一下各位大佬,我用flink cdc2.3连接mysql,用的java进程连接的,连接rds mysql报错no such method?有人遇到过吗,怎么解决呀,我看cdc源码重写了这个类,但是好像他还是执行了debezium里面的那个,是不是和springboot打包有关系呢image.png

展开
收起
cuicuicuic 2023-06-29 08:44:54 45 0
1 条回答
写回答
取消 提交回答
  • 你好,你可以使用 Flink CDC 2.3 连接 MySQL 的 RDS,具体步骤如下:

    创建一个 Flink 程序,并在程序中引入 mysql-cdc 依赖。
    在 SourceFunction 中,创建一个 MySqlSource 对象,并设置 hostname、port、username、password 等参数。
    启动 Flink 程序,并在 Sink 中配置 MySQL 的 RDS 连接。

    2023-09-28 11:10:34
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Spring Cloud Alibaba - 重新定义 Java Cloud-Native 立即下载
    The Reactive Cloud Native Arch 立即下载
    JAVA开发手册1.5.0 立即下载

    相关镜像