编写 Kafka Streams 以持久保存到数据库中是一种好方法吗？

Question

只是想知道在使用 Kafka Streams Builder 编写持久层时我可能会遇到什么样的问题，或者有任何使用建议，例如 Kafka Connect JDBC (Sink)？

Answer 1

是的，使用 Kafka Connect——从主题流式传输到数据存储正是它的用途:)

如果您想 process/enrich 在将数据登陆到数据库之前，您可以使用 KStreams（或 KSQL），并流式传输到第二个主题，然后将其连接到 Connect。