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

Flink CDC中我依赖引入的2.4.1上没有这个方法,为什么?

"Flink CDC中我看github上边mongo sourcebuilder有startup.mode的方法,可是我依赖引入的2.4.1上没有这个方法,为什么?
5e585cc1a41d4105b81bbc0b5fd37d09.jpg
59899533b4dce882e2f835a58cbc11a3.jpg
这是为啥,mongoconnector指定位点消费是2.5才支持的功能吗?


com.ververica
flink-connector-mongodb-cdc

2.4.1

我这个依赖导进来的包然后我刚刚去github下源码自己编译了一下,源码有那个方法的,结果编译完那个方法又没了。"

展开
收起
十一0204 2023-08-16 08:06:17 62 0
1 条回答
写回答
取消 提交回答
  • 意中人就是我呀!

    "import 导包不对,你看看你代码里面的导包路径,是有两个构造器的。
    24e37fb9e54e8d081bd36b9221fd556e.png
    你去导上面的包,别导下面的包。此答案整理至钉群“Flink CDC 社区“。"

    2023-08-16 08:57:46
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 热门讨论

    热门文章

    相关电子书

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