小编Lef*_*ros的帖子

用于 Oracle 数据库源的 Kafka 连接器

我想构建一个 Kafka 连接器,以便近乎实时地从数据库中检索记录。我的数据库是Oracle Database 11gEnterprise Edition Release 11.2.0.3.0,表中有数百万条记录。首先,我想使用 CDC 将最小负载添加到我的数据库中。其次,我想根据某个日期后具有值的 LastUpdate 字段检索记录。

在 confluent 站点搜索,我发现的唯一开源连接器是“Kafka Connect JDBC”. 我认为这个连接器没有 CDC 机制,并且在连接器第一次启动时无法检索数百万条记录。我认为的替代解决方案是 Debezium,但 Confluent 站点上没有 Debezium Oracle Connector,我相信它是测试版。

你会建议哪种解决方案?我对 Kafka Connect JDBC 或 Debezium Connector 的假设有什么问题吗?还有其他解决方案吗?

cdc oracle11g apache-kafka oracle-cdc apache-kafka-connect

5
推荐指数
1
解决办法
4777
查看次数