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

Question

有没有办法进行类似分支的操作​​，但将记录放置在谓词评估为 true 的每个输出流中？ Brach 将记录放置到第一个匹配项(文档:在第一个匹配项上将记录放置到一个且仅一个输出流)。

Answer 1

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

KStream stream = ...

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

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