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



如果我有一个kstream与kv像<String, List<myobject>>,我从kstream组+聚合获得的kstream,是否有一种方法来分割列表的每个值<>获取像<String, myobject>这样的个人信息?我希望像扁平化列表这样的东西可以返回具有相同键的单个消息,但是我找不到kstream(如果有的话)中的哪个方法可能有帮助。我将它们分组以便更容易地进行一些转换,但是,当我希望将这些消息发送到输出主题时,我更愿意单独发送它们。谢谢!

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

将你的列表传递给这个方法,然后加上.to(destinationTopic)应该就可以了。

相关内容

  • 没有找到相关文章

最新更新