【发布时间】：2018-05-14 03:13:03
【问题描述】：
我可以在没有状态的情况下使用转换吗，即使这意味着将密钥更改为其他内容？
注意：我仅限于以下版本（页面）对应的方法：
https://kafka.apache.org/0101/javadoc/org/apache/kafka/streams/kstream/KStream.html
【问题讨论】：
标签： apache-kafka apache-kafka-streams
【发布时间】：2018-05-14 03:13:03
【问题描述】：
是的，您可以在没有状态的情况下使用transform()。请注意，最后一个参数 stateStoreNames 用于选项 var-args 类型 String...，它允许传入零个、一个或多个商店名称。
不确定“即使这意味着将密钥更改为其他内容”是什么意思
【讨论】：
-
谢谢。如果我们重新设置密钥，只是试图想象在没有状态存储的情况下将如何以及在何处保存转换后的结果，它会在转换后仅在内存中吗？
-
如果您不通过
to()将结果流写入主题（例如），结果记录将被删除。这与任何其他运算符的行为相同，例如 map() 或 filter()。