Spring Kafka对接Azure Event Hub时出现认证序列化异常求助

问题根源分析 #

这个错误是Kafka客户端3.6.x版本与Azure Event Hub的SASL PLAIN认证协议交互不兼容，叠加JAAS配置字段错误共同导致的：

1. Kafka 3.6.x的sasl-authenticate响应处理逻辑新增了authBytes字段的非空校验，但Azure Event Hub返回的响应中该字段为空，触发异常。
2. JAAS配置里的username字段填写不符合Azure Event Hub的认证规则。

具体修复方案 #

1. 修正JAAS配置的username字段 #

Azure Event Hub的SASL PLAIN认证有明确要求：

• username必须是纯Event Hub命名空间名称（不带端口、协议前缀）
• password使用完整的Shared Access Key连接字符串（你的配置中这部分是正确的）

修改后的application-azure.yaml配置：

spring:
  kafka:
    bootstrap-servers: {namespace}.servicebus.windows.net:9093
    properties:
      security:
        protocol: SASL_SSL
      sasl:
        mechanism: PLAIN
        jaas:
          config: >-
            org.apache.kafka.common.security.plain.PlainLoginModule required 
            username="{namespace}" 
            password="Endpoint=sb://{namespace}.servicebus.windows.net/;SharedAccessKeyName=KafkaAccess;SharedAccessKey={accesskey}";
      ssl:
        endpoint.identification.algorithm: https

2. 降级Kafka客户端版本（可选，若配置修正后仍报错） #

如果修正配置后authBytes错误依然存在，可将Kafka客户端版本降级到3.5.x（Spring Boot 3.2.x默认依赖3.6.x，需手动指定）：

Maven配置：

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>3.5.3</version>
</dependency>

Gradle配置：

implementation 'org.apache.kafka:kafka-clients:3.5.3'

3. 验证配置有效性 #

重启应用后，确认以下事项：

• 命名空间、SharedAccessKeyName、SharedAccessKey均无拼写错误
• 服务器网络允许9093端口的SSL出站连接

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