Kafka与Ingres数据库集成

Question

我正在尝试将Ingres数据库与Kafka集成。我要找的是，一旦在Ingres数据库中插入/更新/删除了一条记录，它就应该在Kafka主题中发布这条记录。有没有这样的产品/框架可以实现这一点？

在https://developer.adroitlogic.com/connectors/docs/17.07/kafka/kafka_ingress_connector.html上有一些名为"Kafka Ingress“的连接器，但这似乎不适用于Ingres数据库。注意拼写的不同。数据库名称是Ingres，而这个网站上给出的连接器是Ingress。即使我忽略拼写差异，网页也没有提到任何关于Ingres数据库的内容。似乎"Kafka Ingress“这个名字是为了一些不同的目的而起的&它实际上并不是为了Ingres数据库而起的。

我期待着Ingres数据库和Kafka之间的实时集成。如果有人知道这一点，请让我知道。另外，如果adroitlogic的人能确认一下Kafka Ingress连接器，那就太好了。谢谢!

Answer 1

我不知道有什么开源连接器。HVR为Ingres和Kafka提供了实时数据集成，但我假设您需要购买许可证才能使用它。

Answer 2

我不知道有什么预制的框架可以做到这一点，但这也不难。对于这些类型的需求，传统的体系结构解决方案是创建一个rule+procedure，它将更改发布到队列中，并作为自己的表实现，并引发一个事件。然后创建一个简单的C(或其他任何东西)应用程序，该应用程序侦听事件，从队列(表)中提取记录，并发布到使用者应用程序，在本例中为Kafka。

(入口是完全不同的东西，与产品Ingres无关)