我想构建一个 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 的假设有什么问题吗?还有其他解决方案吗?