Spring云流Kafka Binder的一个输入主题多个输出主题

Question

我正在使用Spring Cloud Stream Kafka Binder。我有以下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

如果我想从同一个功能向两个不同的主题发送数据，我需要做什么？

Answer 1

不要使用函数，使用消费者

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

Answer 2

您可以通过命令分隔目标值

destination: output-topic,blah,foo