如何在Kafka主题中编写KTable？就像我们在 KStreams 中使用“to()”一样，如何为 KTable 做到这一点？

Question

由于 KTable 没有“to()”方法，因此在向主题发送任何消息之前我们是否需要始终将其转换为 KStream？或者我们如何在我们的主题中存储 KTable？

Answer 1

是的，为了将a具体化为KTable主题，您需要通过将其转换为常规流（而不是变更日志流）table.toStream().to("myTopic")。