本地SpringBoot应用配置远程Kafka却连localhost的问题排查

本地SpringBoot应用尝试连接远程Kafka服务器（IP：123.45.6.789）时失败，报错显示应用仍在尝试连接localhost/127.0.0.1:9092，具体报错如下：

WARN[0;39m [35m18788[0;39m [2m---[0;39m [2m[ntainer#0-0-C-1][0;39m
[36morg.apache.kafka.clients.NetworkClient [0;39m [2m:[0;39m [Consumer
clientId=consumer-fooss-1, groupId=fooss] Connection to node -1
(localhost/127.0.0.1:9092) could not be established.
Broker may not be available.

本地SpringBoot的application.properties配置：

kafka.bootstrapAddress=123.45.6.789:9092
kafka.groupId=fooss
kafka.topicName=topicMyTopic

远程Kafka的server.properties配置：

broker.id=0

listeners=PLAINTEXT://123.45.6.789:9092
advertised.listeners=PLAINTEXT://123.45.6.789:9092
log.segment.bytes=1073741824 
log.retention.check.interval.ms=300000
zookeeper.connect=123.45.6.789:2181
zookeeper.connection.timeout.ms=18000

注：已通过MobaXterm终端在本地正常生产/消费远程Kafka消息，但SpringBoot应用连接失败，疑问：为何配置了远程地址，应用仍尝试连接localhost？该如何解决？

核心原因 #

SpringBoot Kafka自动配置默认读取的配置键是spring.kafka.bootstrap-servers，而非你自定义的kafka.bootstrapAddress。你的配置没有被框架正确加载，导致应用使用了默认值localhost:9092。

解决步骤 #

方法1：修改配置键为框架默认格式 #

直接调整application.properties中的配置键，符合SpringBoot Kafka自动配置的规范：

spring.kafka.bootstrap-servers=123.45.6.789:9092
spring.kafka.consumer.group-id=fooss
# 可选：配置序列化/反序列化器
# spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
# spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer

方法2：自定义配置绑定（保留自定义键名） #

如果要继续使用kafka.bootstrapAddress这类自定义键，需手动创建配置类绑定属性并构建Kafka客户端：

import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.common.serialization.StringDeserializer;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
import org.springframework.kafka.core.ConsumerFactory;
import org.springframework.kafka.core.DefaultKafkaConsumerFactory;

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

@Configuration
@ConfigurationProperties(prefix = "kafka")
public class KafkaConfig {
    private String bootstrapAddress;
    private String groupId;

    // Getter和Setter
    public String getBootstrapAddress() {
        return bootstrapAddress;
    }

    public void setBootstrapAddress(String bootstrapAddress) {
        this.bootstrapAddress = bootstrapAddress;
    }

    public String getGroupId() {
        return groupId;
    }

    public void setGroupId(String groupId) {
        this.groupId = groupId;
    }

    @Bean
    public ConsumerFactory<String, String> consumerFactory() {
        Map<String, Object> props = new HashMap<>();
        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapAddress);
        props.put(ConsumerConfig.GROUP_ID_CONFIG, groupId);
        props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
        props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
        return new DefaultKafkaConsumerFactory<>(props);
    }

    @Bean
    public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory() {
        ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
        factory.setConsumerFactory(consumerFactory());
        return factory;
    }
}

额外验证点 #

• 确认远程服务器的9092端口已对外开放，可通过telnet 123.45.6.789 9092或nc -zv 123.45.6.789 9092测试连通性
• 重启Kafka服务确保server.properties的配置生效
• 检查SpringBoot应用代码中是否存在硬编码localhost:9092的配置

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