akka-stream - 将来自不同主题的消息保存到 Alpakka 中的不同文件

Question

我试图弄清楚如何将消息从订阅多个主题的 Kafka 消费者传递到基于主题的处理阶段（例如，将它们保存到特定文件或数据库等）。

有一个Consumer.externalCommittableSource，但它需要手动选择分区，这是我想避免的。

一般来说，根据流元素的某些分组属性的值动态创建流和汇的正确方法是什么？

Answer 1

看来您正在寻找groupBy运营商。