java - 将KTable数据放入外部DB

Question

我遇到的情况是，我需要将数据放入 KTable 中，并将 KTable 中的数据存储到 Oracle 11g DB 中。有什么可行的方法吗？

Answer 1

从 Kafka Streams 写入数据库被视为副作用，因此您将独自处理数据库事务等。我建议是在 Kafka Streams 应用程序中进行过滤，然后推送数据回到卡夫卡来说另一个话题。然后，正如 @Matthias J. Sax 建议的那样，您可以利用 Kafka Connect 来使用该主题并将数据写入 RDBMS。