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

Flink CDC在代码里面集成cdc的时候,是不是也要用上面这个胖包?

Flink CDC在代码里面集成cdc的时候,是不是也要用上面这个胖包flink-sql-connector-mysql-cdc,不要去用瘦包flink-connector-mysql-cdc?
com.ververica
flink-sql-connector-mysql-cdc
2.4.0

展开
收起
cuicuicuic 2023-12-01 10:30:36 22 0
4 条回答
写回答
取消 提交回答
  • 是的,Flink CDC在代码里面集成CDC时,需要使用flink-是的,Flink CDC在代码里面集成CDC时,需要使用flink-sql-connector-mysql-cdc这个胖包,而不是flink-connector-mysql-cdc瘦包。因为flink-sql-connector-mysql-cdc包含了更多的功能和配置选项,可以更好地满足Flink CDC的需求。

    2023-12-02 16:35:28
    赞同 展开评论 打赏
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    是的,如果你打算使用Flink SQL来处理CDC数据并利用Flink CDC的功能,那么你应该使用包含SQL支持的胖包,也就是flink-sql-connector-mysql-cdc。这个胖包包含了对SQL的支持,使得你可以使用Flink SQL来定义数据源、转换和接收器等组件。

    瘦包flink-connector-mysql-cdc可能不包含SQL相关的功能,因此在集成到代码中时可能会缺失一些必要的依赖或功能。通常,对于基于Flink SQL的应用场景,推荐使用胖包以确保所有的功能都可以正常工作。

    2023-12-01 21:27:09
    赞同 展开评论 打赏
  • 在Flink CDC中,如果你使用的是Flink SQL来定义和执行CDC任务,那么通常需要使用包含SQL支持的“胖包”(fat jar),即flink-sql-connector-mysql-cdc。这是因为这个胖包包含了运行Flink SQL所需的全部依赖项,包括连接器、序列化器等。相反,如果只使用了瘦包flink-connector-mysql-cdc,你可能会遇到缺少某些依赖的问题,因为在实际运行时还需要其他的库才能完成完整的功能。

    当你在代码中集成Flink CDC时,特别是当使用Flink SQL时,建议使用flink-sql-connector-mysql-cdc这个胖包以确保所有必需的组件都已包含在内。这样可以避免因为缺少依赖而导致的任务失败或错误。

    2023-12-01 16:42:36
    赞同 展开评论 打赏
  • 都用胖包,此回答整理自钉群“Flink CDC 社区”

    2023-12-01 11:17:08
    赞同 展开评论 打赏

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

相关产品

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

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载