如何将消息拆分为更多消息

Question

如果我从 KStream groupby + aggregate 中获得了一个带有像 <String, List<myobject>> 这样的 KV 的 kstream，有没有办法拆分 List<> 的每个值以获得像 <String, myobject>?我希望得到类似扁平化列表的东西，该列表会 return 使用相同密钥的单个消息，但我找不到 kstream 中的哪种方法（如果有的话）可能有帮助。 我将它们分组以便更轻松地进行一些转换，但是，当我想将这些消息发送到输出主题时，我更愿意单独发送它们。 谢谢！

Answer 1

.flatMapValues() - 通过将此流中的每个记录的值转换为新流中具有相同键的零个或多个值来创建新的 KStream。

将您的列表传递给此方法，然后使用 .to(destinationTopic) 应该可以解决问题。