Spring Boot Kafka配置远程broker仍尝试连接localhost:9092问题

架构老林

2026-10-17

问题根因

最常见的原因是你自定义的ConcurrentKafkaListenerContainerFactory没有被@KafkaListener注解绑定使用：Spring Boot自带默认的Kafka监听容器工厂，会读取application配置文件中的spring.kafka.bootstrap-servers参数，如果你没有主动指定使用自定义工厂，且配置文件中没有配置远程broker地址，就会使用默认值localhost:9092发起连接。
其次可能是你的KafkaConfig配置类没有被Spring扫描加载：如果配置类所在包不在启动类默认的扫描路径下，你自定义的消费者工厂和容器工厂都不会生效，程序会使用自动配置的默认Kafka参数。
小概率是spring-kafka与Spring Boot版本不兼容，导致自定义配置不生效。

解决方法

绑定自定义容器工厂
修改@KafkaListener注解，显式指定使用你自定义的工厂：

@KafkaListener(topics = "foo_topic", groupId = "group_1", containerFactory = "concurrentKafkaListenerContainerFactory")
public void consume(String message) {
    log.info(message);
}

确认配置类被扫描
检查KafkaConfig是否在启动类的同级/子包下，如果不在可以在启动类的@SpringBootApplication注解中添加扫描路径：

@SpringBootApplication(scanBasePackages = "你的KafkaConfig所在包路径")

也可以在KafkaConfig类启动时打断点/加启动日志，确认类被正常初始化。

可选：使用全局配置简化代码
如果没有特殊自定义需求，可以删除Kafka配置类，直接在application.properties中添加全局Kafka参数，默认容器工厂会自动读取：

spring.kafka.bootstrap-servers=BROKER_1.FOO.NET:9094
spring.kafka.consumer.group-id=group_1
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer

这种方式不需要修改@KafkaListener注解即可生效。