配置spring.kafka.bootstrap-servers无法连接Docker部署的Kafka Broker

核心问题 #

从日志可以明确看到，Spring Boot的Kafka AdminClient实际尝试连接的是localhost:9092，但你在application.properties中配置的是localhost:29092——这说明你的配置未被正确加载，或者存在其他配置源覆盖了该设置。

另外，ZooKeeper的端口映射（22181:2181）对Spring Boot应用完全没有影响，因为Spring Kafka只需要通过bootstrap servers连接Kafka Broker，不需要直接和ZooKeeper交互。

解决方案 #

1. 确认配置文件有效性 #

检查application.properties是否放在src/main/resources目录下，且配置项无拼写错误：

spring.kafka.bootstrap-servers=localhost:29092

如果使用了多环境配置、环境变量或Spring Cloud Config，排查这些配置源是否覆盖了该值。

2. 代码层面强制指定Bootstrap Servers #

如果配置文件方式不生效，直接在代码中显式配置Kafka客户端参数：

import org.apache.kafka.clients.admin.AdminClientConfig;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.core.KafkaAdmin;

import java.util.HashMap;
import java.util.Map;

@Configuration
public class KafkaConfig {

    @Bean
    public KafkaAdmin kafkaAdmin() {
        Map<String, Object> configs = new HashMap<>();
        configs.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:29092");
        return new KafkaAdmin(configs);
    }
}

对于生产者和消费者，同样可以通过配置类显式指定：

@Bean
public ProducerFactory<String, String> producerFactory() {
    Map<String, Object> configProps = new HashMap<>();
    configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:29092");
    // 其他生产者配置（如key/value序列化器）
    return new DefaultKafkaProducerFactory<>(configProps);
}

@Bean
public ConsumerFactory<String, String> consumerFactory() {
    Map<String, Object> props = new HashMap<>();
    props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:29092");
    // 其他消费者配置（如group id、key/value反序列化器）
    return new DefaultKafkaConsumerFactory<>(props);
}

3. 验证Docker端口映射 #

确认你的Docker Compose中Kafka的端口映射正确：

ports:
  - 29092:29092

该配置将容器内部的29092端口映射到主机的29092端口，外部应用（如你的Spring Boot项目）可以通过localhost:29092访问Broker。

4. 确认Kafka Broker监听配置 #

你的Kafka环境变量配置是正确的：

KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9092,PLAINTEXT_HOST://localhost:29092
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT

这个配置允许容器内部服务通过kafka:9092连接，外部服务通过localhost:29092连接——这和你用Offset Explorer成功连接的逻辑一致，所以Broker本身的配置没有问题。

总结 #

问题的核心是Spring Boot没有正确读取到你配置的localhost:29092，而是使用了默认的localhost:9092。通过检查配置文件的有效性，或在代码中显式指定bootstrap servers，就能解决连接问题。ZooKeeper的端口配置不影响Spring Kafka的连接，无需额外处理。

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