SpringBoot Kafka应用spring.kafka.consumer.ssl.bundle属性使用求助

你已经通过手动配置ConsumerFactory的方式实现了Kafka的SSL连接，但其实Spring Boot 3.2+已经为Kafka自动配置集成了SslBundle支持，用spring.kafka.consumer.ssl.bundle属性可以大幅简化配置，以下是具体实现步骤：

一、核心配置说明 #

spring.kafka.consumer.ssl.bundle的作用是引用你已经定义好的SslBundle实例，而不是替代SslBundle本身的配置，所以不能注释掉bundle的基础定义。

二、正确配置示例 #

1. 完整的application配置 #

# 第一步：定义PEM格式的SslBundle（必须保留，不能注释）
spring.ssl.bundle.pem.mycoolclient.keystore.certificate=/path/to/keystore.cert
spring.ssl.bundle.pem.mycoolclient.keystore.private-key=/path/to/keystore.key
spring.ssl.bundle.pem.mycoolclient.truststore.certificate=/path/to/truststore.cert

# 第二步：指定Kafka消费者使用这个bundle
spring.kafka.consumer.ssl.bundle=mycoolclient

# 其他Kafka基础配置
spring.kafka.bootstrap-servers=ssl-kafka.com:9092
spring.kafka.consumer.group-id=group_id
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.security-protocol=SSL

2. 简化的配置类 #

如果不需要额外自定义Consumer逻辑，完全可以去掉手动创建ConsumerFactory的代码，只保留必要的注解：

import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.annotation.EnableKafka;

@EnableKafka
@Configuration
public class KafkaConfig {
    // 无需自定义ConsumerFactory，Spring Boot自动配置会处理所有SslBundle集成逻辑
}

3. 需自定义ConsumerFactory的场景 #

如果业务需要扩展ConsumerFactory，也可以借助KafkaProperties获取自动配置好的属性（包含SslBundle的注入）：

import org.springframework.boot.autoconfigure.kafka.KafkaProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.annotation.EnableKafka;
import org.springframework.kafka.core.ConsumerFactory;
import org.springframework.kafka.core.DefaultKafkaConsumerFactory;

@EnableKafka
@Configuration
public class KafkaConfig {

    @Bean
    public ConsumerFactory<String, String> consumerFactory(KafkaProperties kafkaProperties) {
        // 直接使用自动配置好的属性，已包含SslBundle相关配置
        return new DefaultKafkaConsumerFactory<>(kafkaProperties.buildConsumerProperties());
    }
}

三、常见问题解释 #

• 之前注释掉SslBundle配置后失效，是因为spring.kafka.consumer.ssl.bundle的值是已定义的bundle名称，必须先通过spring.ssl.bundle.*配置好对应的bundle实例，才能被Kafka消费者引用。
• 不需要手动设置SslBundleSslEngineFactory：当你指定ssl.bundle属性后，Spring Boot自动配置会自动注入对应的引擎工厂，无需手动配置。

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