有没有人用过Flink CDC 的mongodb 的connector，完全无法工作？
有没有人用过Flink CDC 的mongodb 的connector，在flink_cdc 2.3版本，mongodb 4.2 版本？完全无法工作？也没有报错？直接用mongosh，cur = db.collection.watch()，cur.next() 可以，但 flink mongodb cdc不行。我打算直接用mongodb 的python api直接watch测试一下，实在不行就直接用python或java原生的mongodb cdc来做。
flink mongodb cdc一开始就不行，需要手动解依赖，依赖的mongodb jar 包自己跟自己都不兼容，改了半天，跑通了没数据。2.4 snapshot也不行，感觉是没法用了
展开
收起
1
条回答
写回答
写回答
-
你的mogo 是集群模式吗？
我是这个版本，用起来没问题。
官网上说对于2.3版本的flink-mongo-cdc， mongo 要求 3.6 版本以上就可以。
此回答整理自钉群“Flink CDC 社区”2023-07-10 17:47:19赞同 展开评论 打赏
问答标签：
相关产品：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
热门讨论
热门文章
DataWorks如何通过spark访问外网呢？
280
DataWorks这个errcode是什么意思？
356
幻兽帕鲁服务器搭建
1784
机器学习PAI现在一直在重试，怎样停掉？
147
请教一下DataWorks，doris和starRocks 选型，选哪个？
667
如何高效的往交互建模（dsw）上传较大的文件，有从阿里云盘中直接下载或类似的方法吗？
3368
在机器学习PAI为什么有的空间看不到数据源：FeautureDB？
403
DataWorks我该如何访问A项目安装了项目的package资源？
846
实验中 Elasticsearch、es kibana login 的默认用户和口令是什么？
1782
钉钉openPageInWorkBenchForPC和util.invokeWorkb调用没起作用
63
展开全部
阿里云开源离线同步工具DataX3.0介绍
103468
Flink 流批一体场景应用及落地情况
67312
通义千问2(Qwen2)大语言模型在PAI-QuickStart的微调、评测与部署实践
60530
用DataV Atlas探索杭州美食
50818
阿里云PAI大模型评测最佳实践
40768
DataV带你回顾春节前后全国空气质量变化
51070
odps是什么?
68428
权威详解 | 阿里新一代实时计算引擎 Blink，每秒支持数十亿次计算
23158
阿里数据仓库实践分享
15754
【大数据干货】数据进入阿里云数加-大数据计算服务MaxCompute（原ODPS）的N种方式
16167
展开全部
相关电子书
更多
