apache-kafka - KStream 将记录发送到多个流(不是分支)

Question

有没有一种方法可以进行类似分支的操作​​，但将记录放在谓词计算结果为真的每个输出流中？ Brach 将记录放入第一个匹配项(文档:在第一个匹配项中，一条记录被放置到一个且只有一个输出流中)。

Answer 1

您可以单独“广播”和过滤每个流:

KStream stream = ...

stream1 = stream.filter(...);
stream2 = stream.filter(...);
// and so on...

如果多次使用 stream 变量，所有记录都会广播到所有下游过滤器(或任何其他运算符)，即，每个过滤器针对每个记录执行。