我用的是Spring Cloud流Kafka活页夹。我有以下Kafka活页夹功能。
public Function<T1,T2> f() {
return d ->{}
}
在yml中,我有:
spring:
cloud:
steam:
function:
definition:f;
bindings:
f-in-0:
destination: input-topic
f-out-0:
destination: output-topic
如果我想从同一个函数向两个不同的主题发送一个数据,我需要做什么?
2条答案
按热度按时间ruoxqz4g1#
您可以使用逗号分隔目标值
ibrsph3r2#
不要使用函数,使用
Consumer<?>
和StreamBridge
来确定要将消息发送到哪个(些)输出。https://docs.spring.io/spring-cloud-stream/docs/3.2.2/reference/html/spring-cloud-stream.html#_sending_arbitrary_data_to_an_output_e_g_foreign_event_driven_sources