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

Question

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

Answer 1

是的，为了实现KTable主题，您需要通过table.toStream().to("myTopic").

Answer 2

请注意，KTable前一段时间有一个 to 方法。

一般来说，如果你检查旧版本KTable，比如1.0，你会发现 API 得到了显着简化，并且有十几个方法被弃用，其中许多方法从今天开始被删除，包括to()：