Flink CDC里 flink-connector-mongodb-cdc3.0.1 和debezium的兼容版本 ?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
在Flink CDC中,flink-connector-mongodb-cdc
3.0.1版本与Debezium的兼容性问题需要明确说明。根据知识库中的信息,以下是详细解答:
flink-connector-mongodb-cdc
是基于Flink CDC项目独立开发的连接器,并不依赖于Debezium项目。因此,MongoDB CDC连接器不支持Debezium相关的参数。
这意味着,即使您使用的是flink-connector-mongodb-cdc
3.0.1版本,也无法直接使用Debezium的配置参数或功能。
虽然MongoDB CDC连接器本身不依赖Debezium,但在Flink CDC的整体生态中,其他连接器(如Postgres CDC)可能会依赖Debezium。以下是从知识库中提取的Flink CDC与社区版CDC的版本对应关系:
VVR版本 | 社区版本 |
---|---|
vvr-8.0.1-flink-1.17 ~ vvr-8.0.7-flink-1.17 | release-3.0 |
从表中可以看出,flink-connector-mongodb-cdc
3.0.1版本对应的Flink CDC社区版本为release-3.0
。然而,这并不意味着它与Debezium有直接兼容性。
changeStream
权限等),否则可能导致连接失败。flink-connector-mongodb-cdc
3.0.1版本不依赖于Debezium,也不支持Debezium相关的参数或功能。如果您需要使用Debezium的功能,可以考虑其他基于Debezium实现的Flink CDC连接器(如Postgres CDC)。对于MongoDB CDC连接器,建议直接参考其官方文档和配置参数。
如有进一步疑问,请提供更多上下文信息以便更精准地解答。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。