Spring集成Azure EventHub配置AMQP_WEB_SOCKETS仍出现传输类型报错

问题原因 #

报错是因为你自定义的EventHubProducerAsyncClient、EventHubConsumerAsyncClient、EventProcessorClient Bean并没有被Spring Cloud Stream的绑定逻辑使用。Spring Cloud Stream Azure Event Hub Binder会自动根据配置初始化客户端实例，你在自定义Bean中设置的传输类型、代理参数不会作用到这个自动创建的客户端上，自动初始化的客户端默认使用AMQP_TCP传输类型，同时检测到代理配置就会抛出该异常。

解决方案 #

你可以选择以下任意一种方案解决：

• 方案1：使用Spring Cloud Stream配置（推荐，适合用Spring Cloud Stream绑定机制的场景）
  删掉你自定义的客户端Bean，直接在项目的application.yml或application.properties中添加如下配置，Spring Cloud Stream会自动用你配置的参数初始化客户端：

  # 配置传输类型为AMQP Web Socket
  spring.cloud.azure.eventhubs.transport-type=amqp_websockets
  # 配置代理参数
  spring.cloud.azure.eventhubs.proxy.host=my proxy address
  spring.cloud.azure.eventhubs.proxy.port=8080
  spring.cloud.azure.eventhubs.proxy.authentication-type=none
  # 其他Event Hub、存储 checkpoint 相关配置保持原有即可
  

• 方案2：禁用Spring Cloud Stream Event Hub自动绑定（适合自己管理客户端实例的场景）
  如果你确定要使用自己定义的客户端Bean，不需要Spring Cloud Stream的绑定功能，就关闭Event Hub Binder的自动配置，在配置文件中添加：

  spring.autoconfigure.exclude=org.springframework.cloud.stream.binder.eventhubs.EventHubsBinderAutoConfiguration
  

  关闭后Spring Boot启动时就不会再触发BindingService的客户端创建逻辑，只会加载你自定义的Bean。

额外检查建议 #

确认你项目的Azure Event Hub SDK和Spring Cloud Azure依赖版本使用官方BOM统一管理，避免版本不兼容导致的配置不生效问题。

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