来自两个不同的Kafka代理的Spring云流处理器

对于一个输入流和两个输出,kafki是否可能绑定到一个流上。

换句话说,我希望我的流在一个Kafka代理中监听,并在另一个Kafka代理中编写输出。

@StreamListener(Processor.INPUT)
@SendTo(Processor.OUTPUT)
public Object handle(String message) {
    // Processor.INPUTbeing bind to one Kafka broker
    // Processor.OUTPUT being bind to another Kafka broker
    // Write the logic here
}