如何使用两个不同的输入主题启用函数路由

Question

我正在将一个应用程序迁移到SpringCloudStream的新的基于功能的编程模型中，但阻止了事件路由。

我必须路由来自两个不同kafka主题的事件，我不知道如何将functionRouter-in-0绑定到两个不同的目的地。

路由可以通过添加spring.cloud.function来完成。definition＜/code＞头到生产者端的每个消息。

假设我有

• 我的服务中有4个消费者功能：consumerA、consumerB、consumerC、consumerD
• 2个kafka主题：＜ul＞
• topic1，其中包含带有spring.cloud.function的消息。具有值consumerA或consumerB的定义标头
• topic2，其消息头的值为consumerC或consumerD

我如何在配置中表达RoutingFunction.FUNCTION_NAME应该听Topic1和Topic2？

spring:
  cloud:
    function.definition: consumerA;consumerB;consumerC;consumerD
    stream:
      function.routing.enabled: true
      bindings:
        functionRouter-in-0:
          destination: topic1
          group: myService
          consumer:
            concurrency: 1
            partitioned: false
            maxAttempts: 1
        functionRouter-in-0:   # <== this oviously does not work because it's already defined above
          destination: topic2
          group: myService
          consumer:
            concurrency: 3
            maxAttempts: 1

注意:我的版本是3.0.11.RELEASE




Answer 1

关于绑定，基于注释的模型没有任何变化，正如这里所解释的那样 - “如果绑定表示消费者绑定（输入），它可以绑定到多个目标，并且目标名称可以指定为逗号分隔的字符串值。 所以。。。.

. . .
functionRouter-in-0:
          destination: topic1, topic2
          group: myService
. . .

我认为剩下的部分在这里进行了解释，其中讨论了路由到和从，以及可以使用的不同机制，例如应用程序属性、消息头等。

此外，对于出站也有几个选项。一个是StreamBridge和… sendto…标头。

请随时跟进。