Kafka 流是否可以将输出写入两个不同的主题？

Question

我需要一个流来对来自主题 A 的值进行分组，将分组值发送到主题 B，然后在翻滚时间窗口内将这些分组值的总和发送到主题 C。 卡夫卡可以做到吗？还是只能从一个主题读取和写入流？

Answer 1

是的。例如，您可以拆分输入流并写入不同的主题：

KStream stream = ...
KStream[] splitStream = stream.branch(...);

splitStream[0].to("topic-1");
splitStream[1].to("topic-2");

您还可以通过to(TopicNameExtractor) 使用更动态的方法。

您还可以“广播”流以应用不同的逻辑。重复使用相同的KStream 变量可确保通过多个并行下游操作在逻辑上复制和处理每条记录：

KStream stream = ...

KStream filterdStream = stream.filter();
KTable count = stream.groupBy().count();