Spring Cloud Stream事件路由Bindings配置及使用相关问题咨询

问题1解答 #

只要processB、processC加了@Component注解且被Spring上下文扫描到，不需要额外在spring.cloud.function.definition中声明也可以被functionRouter自动调用，definition配置项仅用于声明需要作为独立绑定入口的函数，你当前配置里把它们加进去也不会产生副作用，不属于错误配置。

问题2解答 #

不需要为processB单独配置输出binding。
processB是被functionRouter触发调用的子函数，它的输出会自动绑定到functionRouter的输出绑定functionRouter-out-0，你当前配置中单独加的processB-out-0属于无效配置，因为processB没有独立的输入绑定，不会作为独立的流端点被触发。你只需要补充配置functionRouter-out-0的目标destination即可完成路由后消息的输出。

另外你当前的配置还缺少processA-out-0的绑定配置，processA返回的带路由头的消息需要发送到route-event主题才能被functionRouter接收，建议补充调整如下配置：

spring:
  cloud:
    stream:
      bindings:
        # 补充processA的输出绑定
        processA-out-0:
          destination: route-event
        # 补充functionRouter的输出绑定
        functionRouter-out-0:
          destination: 你需要输出的最终目标topic
        # 可删除无效的processB-out-0配置

问题3解答 #

你看到的Consumer does not have output type报错和functionRouter无关，是你的ProcessC代码写法错误导致的：ProcessC实现了Consumer<PojoObj>接口，accept方法的返回值必须是void，你当前代码写的返回PojoObj不符合接口规范，框架检测到Consumer类型没有输出通道，所以抛出了该提示。
StreamBridge是Spring Cloud Stream官方推荐的、在函数内部主动发送消息的方案，你这个场景下使用是完全合理的。需要注意的是你当前把processC-out-0绑定到了process-event主题，而processA的输入也是process-event，要避免逻辑上的循环调用问题。如果你的需求是ProcessC处理完直接走processB校验，可以直接给StreamBridge发送的消息加上spring.cloud.function.definition=processB头，发送到route-event主题即可，不需要再绕回process-event。

内容的提问来源于stack exchange，提问作者Kitch205