1

我有一个键控数字流,它们会运行到(Windowed).countByKey()中,然后在.forEach().

我想采用 Windowed 值,将它们与 start 和 end 值配对并将其放入一个新流中。我可以使用“传统”制作人来做到这一点,但我希望将所有工作都保存在一个应用程序中(而不是让第二个应用程序来处理新主题中的值)。

.forEach()KTable <Windowed<String>, Long>的形式出现,我没有看到明显的运算符将其(通过.to().through())链接到KStream<String, String>主题。

这可能吗?这个问题有意义吗?

4

0 回答 0