如何在Kafka主题中写KTable？就像我们在KStreams中使用 "to() "一样，如何在KTable中写？

Question

由于KTable没有 "to() "方法，所以我们是否需要在发送任何消息到话题之前，总是将其转换为KStream？或者说，我们如何在话题中存储KTable？

Answer 1

是的，为了实现一个 KTable 到一个主题，您需要通过以下方式将其转换为普通流（而不是变更日志流 table.toStream().to("myTopic").