将KTable数据放入外部数据库

我有一个场景，我需要将数据放入KTable中，并将该数据从KTable存储到Oracle 11g数据库中。什么是可能的方式来做到这一点？将KTable数据放入外部数据库

2017-10-09 Amit

所有你想要的是把数据放入'KTable'？没有任何转换等？ – Arek

查看Kafka Connect和相应的连接器：https://www.confluent.io/product/connectors/ –

@Arek是的，我必须执行转换，比如只放入那些具有一些匹配表名的数据。 – Amit

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

2017-10-10 09:02:21 Arek

Kafka Connect也支持简单转换的“单一消息转换” - 所以如果你的转换足够简单，你就不需要Kafka Streams。 –

回答