flink cdc 限制支持 ob oracle 模式吗?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
Flink CDC 对 OceanBase(OB)Oracle 模式的支持存在一定的限制,具体如下:
OceanBase 连接器的兼容模式
根据知识库资料,OceanBase 连接器支持两种兼容模式:MySQL 兼容模式和 Oracle 兼容模式。然而,在使用 Flink CDC 时,OceanBase 的 Oracle 兼容模式并不完全支持通过 OCJ(OceanBase Connector Java)驱动进行连接。如果 OceanBase 数据库未部署数据库代理服务,则只能用于 MySQL 兼容模式,而不支持 Oracle 兼容模式。
推荐使用数据库代理服务
在 OceanBase 中,数据库代理服务与 OCJ 驱动实现了相同的路由功能。但 OceanBase 官方团队更推荐通过数据库代理服务来连接 OceanBase 集群,尤其是在需要支持 Oracle 兼容模式的场景下。OCJ 驱动主要用于兼容一些历史集群和应用程序。
Flink CDC 的限制
当前 Flink CDC 对 OceanBase 的支持主要集中在 MySQL 兼容模式下。对于 Oracle 兼容模式,由于技术实现上的限制(如 OCJ 驱动不支持 Oracle 模式),Flink CDC 并未完全支持 OceanBase 的 Oracle 模式。
解决方案建议
如果您需要在 Oracle 兼容模式下使用 Flink CDC,可以考虑以下方案:
总结:Flink CDC 目前对 OceanBase 的 Oracle 兼容模式支持有限,主要受限于 OCJ 驱动的技术实现。建议优先使用数据库代理服务或切换至 MySQL 兼容模式以满足需求。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。