Spring Boot整合Kafka消费者出现bootstrap broker disconnected错误

你遇到的报错本质是SSL握手失败导致连接被Broker主动断开，优先从配置加载优先级、环境权限两个维度排查： #

1. 验证自定义消费者配置是否生效 #

Spring Boot会自动装配默认的KafkaListenerContainerFactory，如果你手动加载的consumer.properties（含SSL、Schema Registry配置）没有绑定到监听器工厂，会导致SSL配置完全不生效，直接以明文方式请求SSL端口9093被断开：

• 检查自定义KafkaListenerContainerFactory的Bean是否添加了@Primary注解，或者在@KafkaListener注解中显式指定了containerFactory属性指向自定义的工厂Bean
• 在初始化消费者配置后打印全量配置项，确认security.protocol、SSL密钥库/信任库路径、密码等配置是否存在且值正确，没有被application.properties的配置覆盖

2. 检查SSL证书文件访问权限 #

本地运行正常但其他环境失败，大概率是Spring Boot进程没有证书文件的读取权限：

• 验证some_path.jks文件在运行环境的实际路径是否正确，使用File.exists()方法打印路径可用性
• 确认运行Spring Boot进程的操作系统账号，是否拥有该jks文件的读取权限

3. 开启DEBUG日志排查握手细节 #

在application.properties中添加如下配置开启Kafka安全相关日志，可直接定位SSL握手失败的具体原因：

logging.level.org.apache.kafka.common.security=DEBUG
logging.level.org.apache.kafka.clients.NetworkClient=DEBUG

常见的握手失败原因包括：TLS版本不匹配、证书过期、域名和证书SAN不匹配、密钥库密码错误等。 #

4. 其他兼容&网络验证 #

• 统一kafka-clients依赖版本：将Spring Boot依赖树中的kafka-clients版本，调整为和你可用的非Spring消费代码使用的版本完全一致，避免版本不兼容问题
• 验证网络连通性：在Spring Boot运行环境执行telnet my_address 9093确认网络可达，排除容器/防火墙的隔离规则问题

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