我们正在构建一个系统,使用名为qlik的产品将数据从sybase迁移到oracle,它还提供了cdc
这是我的设想
qlik工具将为每个表创建kafka主题,并从sybase db发布所有数据
topic中的每条消息都有一些元数据,其中一条会告诉我们它的insert/update/delete
另一方面,我们必须构建使用者层来从每个主题中提取数据,并在oracledb中更新/同步相应的表
我想什么是更好的方法来建立消费者层。非常感谢您的帮助
我们正在构建一个系统,使用名为qlik的产品将数据从sybase迁移到oracle,它还提供了cdc
这是我的设想
qlik工具将为每个表创建kafka主题,并从sybase db发布所有数据
topic中的每条消息都有一些元数据,其中一条会告诉我们它的insert/update/delete
另一方面,我们必须构建使用者层来从每个主题中提取数据,并在oracledb中更新/同步相应的表
我想什么是更好的方法来建立消费者层。非常感谢您的帮助
1条答案
按热度按时间332nm8kg1#
最后,您需要一个使用者和模式推理来将字段存储在表中。
kafka connect jdbc接收器可以很好地工作和扩展,但“更好”是相对的,这取决于您的预期结果。