Spring Kafka消费者配置未生效，SSL参数为空致连接失败

核心问题根源 #

你的Kafka消费者SSL配置未生效，本质是配置属性注入失败+消费者基础配置错误，导致连接Broker时SSL参数为空，最终连接失败。

错误1：反序列化类使用错误 #

消费者配置中错误使用了生产者的序列化器StringSerializer，消费者必须使用反序列化器：

// 错误写法
props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringSerializer.class);
props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringSerializer.class);

// 正确写法
props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);

错误2：配置属性路径不匹配 #

你将Kafka专属的SSL配置放在了全局spring.ssl/spring.security节点下，但Spring Kafka的SSL配置必须放在spring.kafka.ssl/spring.kafka.security节点中，同时抽象类的@Value注入路径错误，导致SSL变量为空。

修正application.yml配置

spring:
  kafka:
    bootstrap-servers: localhost:9092
    # 将Kafka安全配置移到kafka节点下
    security:
      protocol: SSL
    ssl:
      trust-store-location: <path>\java.truststore.jks
      trust-store-password: Pass
      key-store-location: <path>\java.keystore.jks
      key-store-password: Pass

修正抽象类的@Value注入路径

@Value("${spring.kafka.bootstrap-servers}")
protected String bootstrapServers;

// 改为Kafka专属的安全协议路径
@Value("${spring.kafka.security.protocol}")
protected String securityProtocol;

// 改为Kafka专属的SSL配置路径
@Value("${spring.kafka.ssl.trust-store-location}")
protected String trustStoreLocation;

@Value("${spring.kafka.ssl.trust-store-password}")
protected String trustStorePassword;

@Value("${spring.kafka.ssl.key-store-location}")
protected String keytStoreLocation;

@Value("${spring.kafka.ssl.key-store-password}")
protected String keytStorePassword;

错误3：容器工厂的冗余实例创建 #

在容器工厂方法中，你已经注入了ConsumerFactory实例，却重复调用consumerFactory()创建新实例，应直接使用注入的实例：

@Bean
public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<String, String>> factory(
        ConsumerFactory<String, String> consumerFactory
){
    ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
    // 使用注入的consumerFactory，而非重新创建
    factory.setConsumerFactory(consumerFactory);
    return factory;
}

验证方法 #

修改完成后重启服务，查看ConsumerConfig日志，确认以下SSL参数已正确加载（不再为null）：

• ssl.truststore.location
• ssl.truststore.password
• ssl.keystore.location
• ssl.keystore.password
• security.protocol

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