apache-kafka 一个输入主题多个输出主题的Spring Cloud StreamKafka活页夹

bxjv4tth  于 2022-11-01  发布在  Apache
关注(0)|答案(2)|浏览(94)

我用的是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

如果我想从同一个函数向两个不同的主题发送一个数据,我需要做什么?

ruoxqz4g

ruoxqz4g1#

您可以使用逗号分隔目标值

destination: output-topic,blah,foo
ibrsph3r

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

相关问题