Spring 云数据流一个处理器将海关数据发送到多个接收器

Question

在 Spring SCDF 中，我有一个只有一个输入的处理器，我想根据数据类型将数据发送到 3 个不同的接收器，例如：整数到 sink1，字符串到 Sink3 和 Longs 到 SInk3，每个接收器应该能够使用来自处理器

我试过类似的东西。

@Bean
    public Function <String, Tuple3<Flux<String>,Flux<String>, Flux<String>>> sort() {
        return srt -> {
           XXXXX
           XXXXXX
            return Tuples.of(Flux.just(data1), Flux.just(data2),Flux.just(data3));


        };
    }

stream create --name test1 --definition "source  --server.port=1001 | worker || sink1 || sink2  || sink3"

Answer 1

这个例子有多个流应用程序将消息发送到特定的输出。

https://github.com/spring-cloud/spring-cloud-dataflow-samples/tree/main/restaurant-stream-apps

您还可以查看 Router Sink 以获取灵感。 https://github.com/spring-cloud/stream-applications/tree/2021.1.x/applications/sink/router-sink