动态 Akka 流下沉

Question

我想在 Akka 流中构建一个图，其中源是 Kafka 主题 (topic_a)，接收器是 topic_b（始终），并且根据消息的数据，还 topic_c（输出消息将不同于发送到 topic_b 的输出消息）。

有什么方法可以在 Akka 流中实现这一点吗？谢谢！

Answer 1

您需要这样的图表：

topicASource ~> broadcast               ~> topicBSink
                broadcast ~> filterFlow ~> topicCSink 

可以使用 graphs or simplified API 轻松创建。