我一直在试图找到在单个oracle11gr2示例中捕获更改通知并将这些事件传递到apachekafka队列的最有效的方法，但我还没有找到任何简单的示例或教程。
我已经看到了oracle方面的一些可能性（流、变更数据捕获、触发器（恶心）等等），但我仍然不确定哪一个是最好的选择。
这是一个在github上使用mysql和kafka的项目，名为mypipe，我只是没有看到任何类似的oracle。我不确定是否最好集中精力为此编写一个oracle包，或者一个类似mypipe项目的层，等等。。
如有任何建议、建议或示例，将不胜感激。谢谢您。
2条答案
按热度按时间zzzyeukh1#
我认为一种方法可能是利用oraclegoldengate来处理大数据（我自己也在研究这个问题），很明显，这很可能是一个成本高昂的解决方案（美元）？
https://blogs.oracle.com/dataintegration/entry/introducing_oracle_goldengate_for_big
如果你有任何发现，请告诉我，祝你好运。。。
j13ufse22#
目前只有一个工具是开源的，对数据库的影响最小。这是openlogreplicator。
许可证是gpl-它是完全开源的
它对源数据库的影响非常小—它不需要许可选项，只需在源数据库上打开补充日志（与所有其他复制工具一样）
它完全是用c++编写的，因此具有非常低的延迟和高的吞吐量
它完全在记忆中起作用
它支持自11.2.0.1（11.2、12.1、12.2、18、19）以来的所有oracle数据库版本
它读取oracle重做日志的二进制格式并将其发送给kafka。它可以在数据库主机上工作，但您也可以将其配置为使用sshfs从另一个主机读取重做日志—数据库负载最小。
免责声明#1:我是此解决方案的作者
免责声明#2:对于其他stackoverflow用户：请不要删除此答案。这个问题有很多重复的地方。但这是第一个问题，其他副本应该重定向到这里并标记为副本。不是另一种方式。我已经删除了其他问题的所有其他答案，只留下这个答案作为主要答案。