Azure AKS部署Spring Boot应用无法构造Kafka生产者问题求助

排查步骤 #

1. 补充完整错误日志
   当前你展示的报错没有给出生产者创建失败的具体根因，先将项目中org.apache.kafka和org.springframework.kafka的日志级别调整为DEBUG，重启Pod后重新复现问题，即可拿到具体错误原因（是SSL握手失败、SASL认证失败、网络不通还是配置错误）。
   日志配置示例（application.yml）：

logging:
  level:
    org.apache.kafka: DEBUG
    org.springframework.kafka: DEBUG

2. 验证AKS集群到Kafka Broker的网络连通性
   这是AKS部署对接外部中间件最常见的问题，先进入运行的Pod内测试端口连通性：

kubectl exec -it <你的Pod名称> -- nc -zv <你的Confluent Cloud域名> 9092

如果连通失败，说明AKS的NSG、防火墙、网络策略没有放开到Confluent Cloud 9092端口的出站权限，联系集群运维开通即可。

3. 检查SASL配置正确性
   确认AKS环境注入的sasl.jaas.config配置没有转义错误、遗漏字符，标准的PLAIN模式jaas配置格式如下，注意末尾必须带分号：

org.apache.kafka.common.security.plain.PlainLoginModule required username="你的API_KEY" password="你的API_SECRET";

如果是通过Secret、ConfigMap注入配置，要确认注入的值和本地配置完全一致，没有多余的换行、空格。

4. 验证SSL协议&JDK版本兼容性
   如果你怀疑是TLS版本导致的问题，可以先在AKS侧将SSL配置调整为和本地一致，在KafkaProducerConfig的配置Map中新增以下配置：

import org.apache.kafka.common.config.SslConfigs;
// 其他代码省略
configProperties.put(SslConfigs.SSL_PROTOCOL_CONFIG, "TLSv1.3");
configProperties.put(SslConfigs.SSL_ENABLED_PROTOCOLS_CONFIG, new String[]{"TLSv1.2", "TLSv1.3"});

同时确认AKS环境运行的JDK版本支持你配置的TLS版本：JDK8 8u261之前的版本对TLSv1.3支持不完善，如果本地运行用的是JDK11+，AKS用的是低版本JDK8，也会触发SSL相关的初始化错误。

5. 验证客户端版本兼容性
   确认你项目中使用的kafka-clients依赖版本和Confluent Cloud的Broker版本兼容，避免版本不匹配导致的初始化失败。

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