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

flinkcdc 能读到数据,写不到mysql里 ,有遇到过吗?

flinkcdc mongo to mysql JdbcSink 能读到数据,写不到mysql里 ,有大佬遇到过吗?用 RichSinkFunction 自定义的sink就可以写入mysql。sql 也能成功,就jdbcsink不行,是不支持吗?

展开
收起
cuicuicuic 2024-01-09 11:45:06 37 0
2 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    Flink CDC 的 JdbcSink 不支持将数据写入到 MySQL 数据库中。JdbcSink 主要用于将数据写入到支持 JDBC 协议的数据库中,而 MySQL 使用的是自己的协议。因此,您需要使用 RichSinkFunction 自定义的 sink 来将数据写入到 MySQL 数据库中。

    如果您使用 RichSinkFunction 自定义的 sink 可以成功将数据写入到 MySQL 数据库中,那么说明 Flink CDC 是支持将数据写入到 MySQL 中的。可能是由于 JdbcSink 的配置或参数不正确导致无法写入数据。建议您检查 JdbcSink 的配置和参数是否正确,并确保您的 MySQL 数据库连接信息是正确的。

    2024-01-09 15:10:08
    赞同 展开评论 打赏
  • 尝试下强制测试一条就刷出去或者1秒一条就刷出去,此回答整理自钉群“Flink CDC 社区”

    2024-01-09 12:26:13
    赞同 展开评论 打赏

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

相关电子书

更多
搭建电商项目架构连接MySQL 立即下载
搭建4层电商项目架构,实战连接MySQL 立即下载
PolarDB MySQL引擎重磅功能及产品能力盛大发布 立即下载

相关镜像