Flink CDC release-2.4.0支持对OceanBase Oracle 模式做CD吗？

Flink CDC中 release-2.4.0 支持对OceanBase Oracle 模式做CDC么？

展开

收起

十一0204 2023-07-26 08:04:11 76 0

3 条回答

写回答

取消提交回答

Star时光
根据 Flink CDC 的官方文档，截至目前（2021年12月），Flink CDC 尚不支持直接对 OceanBase Oracle 模式进行 Change Data Capture（CDC）操作。

Flink CDC 目前主要支持以下几个数据库的 CDC：
- MySQL
- PostgreSQL
- Oracle
- SQL Server
虽然 OceanBase 是一个基于分布式架构的关系型数据库，与 Oracle 存在一些相似之处，但由于其内部结构和协议的差异，Flink CDC 还未提供专门支持 OceanBase Oracle 模式的功能。

如果你希望在 Flink 中实现对 OceanBase Oracle 模式的 CDC 操作，可能需要自行开发或寻找第三方工具来实现。你可以考虑查看 OceanBase 提供的官方文档或社区资源，以了解是否有其他方式或工具可用于实现 OceanBase Oracle 模式的 CDC。

请注意，Flink CDC 和 OceanBase 的集成是一个较新的场景，因此可能仍在不断发展和改进中。建议及时关注 Flink CDC 和 OceanBase 的最新版本和相关更新，以获取最新的功能和支持。
2023-07-31 23:20:22

赞同展开评论打赏
算精通

北京阿里云ACE会长

Flink CDC release-2.4.0 官方并未支持对 OceanBase Oracle 模式进行 CDC，但是您可以通过自行扩展 Flink CDC 来支持该功能。具体来说，您需要实现自己的 Debezium Connector，以便将 OceanBase Oracle 模式中的数据捕获并输出到其他数据源。
Debezium Connector 是 Flink CDC 的核心组件之一，用于捕获关系型数据库中的数据变化。如果您想要支持 OceanBase Oracle 模式的 CDC，可以通过实现自己的 Debezium Connector 来实现该功能。具体来说，您需要完成以下步骤：
实现 Debezium Connector 接口：您需要实现 Debezium Connector 接口，并根据 OceanBase Oracle 模式的数据结构，编写相应的数据解析逻辑。
配置 Flink CDC：在 Flink CDC 中，需要配置相应的连接信息和参数，以便与 OceanBase Oracle 模式建立连接，并使用自己实现的 Debezium Connector 进行 CDC 监控。
测试和优化：完成上述步骤后，需要对自己实现的 Debezium Connector 进行测试，并根据实际情况进行优化和改进。

2023-07-29 16:49:59

赞同展开评论打赏
意中人jswy

意中人就是我呀！

支持的，不过要用企业版的logproxy。此回答整理至钉群“Flink CDC 社区”。

2023-07-26 12:02:55

赞同展开评论打赏