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

Question

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

Answer 1

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

如果您想在将数据登录到数据库之前对其进行处理/丰富，您可以使用 KStreams（或 KSQL），并流式传输到第二个主题，然后您将其连接到 Connect。