使用kafka消息系统查询oracle数据库

query on oracle database using kafka messaging system

我有一个 oracle 数据库,它是一个数据仓库,我正在使用 kafka 消息传递系统在我的系统中交换消息。在我的灾难恢复解决方案中,我将使用 kafka connect 查询 oracle 数据库,然后将查询的消息复制到 H2 数据库。你们有使用kafka connect查询oracle数据库的解决方案吗?我不会使用像 "confluent" 这样的任何第三方软件解决方案,我也不想使用 kafka API!

请帮助!!

如果您已经在使用 Kafka,那么 Kafka connect 将非常适合您的情况。您可以从 Oracle 数据库中读取并使用 Kafka connect source and then configure a Kafka Connect Sink 将其提供给 Kafka 主题以将其提供给您的 H2 数据库。