配置Spring Cloud Stream对接Azure Event Hub使用服务主体认证报错如何解决

• 认证组件不匹配：你当前配置使用的PlainLoginModule是SAS密钥认证专用的登录实现类，服务主体走的是OAuth 2.0认证流程，完全不兼容该类；同时你配置的SASL机制PLAIN也只适用于SAS密钥，服务主体需要用OAUTHBEARER机制。
• 配置字符串语法错误：JAAS的password配置里嵌套了双引号（client-secret="<<secretID>>"），外层已经用双引号包裹整个password值，直接导致配置被截断，JAAS解析时无法识别完整参数，才抛出参数缺失的错误。
• 配置逻辑冗余：你已经在spring.cloud.stream.azure下声明了client-id和client-secret，又在JAAS配置里重复硬编码，容易出现参数不一致的问题。

手动配置Kafka binder方式 #

如果要直接通过Kafka binder对接Event Hub，使用修正后的配置即可：

spring:
  cloud:
    stream:
      bindings:
        input:
          binder: helixInput
          destination: <你的Event Hub名称>
          group: ${CONSUMER_GROUP:}
      binders:
        rabbitOutput:
          type: rabbit
          environment:
            spring:
        helixInput:
          type: kafka
          environment:
            spring:
              cloud:
                stream:
                  kafka:
                    binder:
                      brokers: <你的Event Hub命名空间>.servicebus.windows.net:9093
                      configuration:
                        sasl:
                          jaas:
                            config: org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required clientId="<服务主体客户端ID>" clientSecret="<服务主体密钥>" scope="<你的Event Hub命名空间>/.default";
                          mechanism: OAUTHBEARER
                        security:
                          protocol: SASL_SSL
                        oauth:
                          bearer:
                            token:
                              endpoint:
                                url: https://login.microsoftonline.com/<你的Azure租户ID>/oauth2/v2.0/token

更简洁的官方适配方案 #

如果使用spring-cloud-azure-starter-stream-eventhubs依赖，可以完全省略手动JAAS配置，只需要配置公共的Azure认证参数即可，大幅降低配置出错概率：

spring:
  cloud:
    azure:
      credential:
        client-id: <服务主体客户端ID>
        client-secret: <服务主体密钥>
      profile:
        tenant-id: <Azure租户ID>
      eventhubs:
        namespace: <你的Event Hub命名空间>
    stream:
      bindings:
        input:
          binder: eventhubs
          destination: <你的Event Hub名称>
          group: ${CONSUMER_GROUP:}
      binders:
        rabbitOutput:
          type: rabbit
        eventhubs:
          type: eventhubs

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