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

【问题标题】：How to write KTable in a Kafka topic? Like we use "to()" in KStreams how to do that for KTable?如何在 Kafka 主题中编写 KTable？就像我们在 KStreams 中使用“to()”一样，如何为 KTable 做到这一点？
【发布时间】：2020-09-20 15:05:37
【问题描述】：

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

【问题讨论】：

标签： apache-kafka apache-kafka-streams spring-kafka ktable

【解决方案1】：

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

一般来说，如果您查看 KTable 的旧版本，例如 1.0，您会发现 API 得到了显着简化，并且有十几个方法被弃用，其中许多方法截至今天已被删除，包括 @ 987654326@:

【讨论】：

【解决方案2】：

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

【讨论】：