如何在Spring Cloud Stream中消费两个Azure Event Hub实例的消息

1. 核心调整项 #

你遇到的问题由两个配置错误导致：一是低版本Spring Cloud Function不支持分号作为多函数分隔符，二是连接字符串和绑定配置重复指定Event Hub名称导致解析冲突。调整后的完整YAML配置如下：

spring:
  cloud:
    stream:
      function:
        definition: consumeRegion1,consumeRegion2
      bindings:
        consumeRegion1-in-0:
          destination: my-request
          binder: eventhub1
          group: $Default
        consumeRegion2-in-0:
          destination: my-request
          binder: eventhub2
          group: $Default
      binders:
        eventhub1:
          type: eventhub
          default-candidate: false
          environment:
            spring:
              cloud:
                azure:
                  eventhub:
                    connection-string: Endpoint=sb://region1.servicebus.windows.net/;SharedAccessKeyName=abc;SharedAccessKey=123
        eventhub2:
          type: eventhub
          default-candidate: false
          environment:
            spring:
              cloud:
                azure:
                  eventhub:
                    connection-string: Endpoint=sb://region2.servicebus.windows.net/;SharedAccessKeyName=def;SharedAccessKey=456

调整说明：

• 多函数定义的分隔符从;改为,，2.5.0版本绑定器对应的Spring Cloud Function版本默认使用逗号作为分隔符
• 移除了两个连接字符串中的EntityPath=my-request参数，绑定配置的destination已经指定了Event Hub名称，重复配置会导致连接初始化失败
• 为每个消费绑定显式指定消费组，Azure Event Hub要求消费端必须关联消费组，避免默认组识别异常

2. 版本校验 #

确认你的Spring Boot版本为2.5.x系列，和azure-spring-cloud-stream-binder-eventhubs 2.5.0版本匹配，跨大版本会出现配置加载异常。

3. 可选优化（消除警告） #

日志中No event hub connection string provided是全局Event Hub自动配置触发的警告，不影响多绑定器的正常运行。如果要消除该警告，可以在全局配置下添加dummy配置：

spring:
  cloud:
    azure:
      eventhub:
        connection-string: dummy

你已将两个绑定器的default-candidate设为false，全局配置不会被实际使用。

你现有的消费逻辑代码、Maven依赖无需修改，调整完配置即可正常消费两个区域的Event Hub消息。

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