Kafka消费者构建失败：bootstrap.server无可用URL，配置读取问题求助

报错信息：构建Kafka消费者失败，根因：org.apache.common.config.ConfigException: bootstrap.server中未提供可解析的URL

问题场景 #

我的配置类代码片段如下：

@Configuration
class TopicConfiguration {

private ConsumarFactory<String, String> creteConsumer(String id) {
Map<String, String> config = new hashMap<>();
config.put(ConsumerConfig.BOOTSTRAP_SERVER_CONFIG, configProperties.getBootstrapServers);
// 省略后续代码
}
}

当硬编码配置值为以下内容时可以正常运行：

config.put(ConsumerConfig.BOOTSTRAP_SERVER_CONFIG, "localhost://8080");

但需要从配置文件中读取bootstrap servers的值，请问该如何解决？

解决方法 #

1. 修正配置文件的地址格式

Kafka的bootstrap.servers正确格式是host:port（多个地址用逗号分隔，例如localhost:9092,192.168.1.100:9092），不要添加//。根据你的配置文件类型调整：

• application.properties：

  spring.kafka.bootstrap-servers=localhost:9092
  

• application.yml：

  spring:
    kafka:
      bootstrap-servers: localhost:9092
  

2. 确保配置属性类正确绑定

创建或检查你的配置属性类，确保它正确映射配置文件中的值：

@ConfigurationProperties(prefix = "spring.kafka")
@Component
public class KafkaConfigProperties {
    private String bootstrapServers;

    // 必须提供getter方法
    public String getBootstrapServers() {
        return bootstrapServers;
    }

    // 必须提供setter方法（Spring需要通过setter注入值）
    public void setBootstrapServers(String bootstrapServers) {
        this.bootstrapServers = bootstrapServers;
    }
}

注意：如果没有给类加@Component，需要在配置类上添加@EnableConfigurationProperties(KafkaConfigProperties.class)来启用属性绑定。

3. 修复代码中的拼写与语法错误

你的代码存在几处拼写和语法问题，会导致配置读取失败：

• ConsumarFactory → 正确类名是ConsumerFactory
• creteConsumer → 正确方法名是createConsumer
• hashMap → 正确类名是HashMap
• configProperties.getBootstrapServers → 需调用方法，改为configProperties.getBootstrapServers()

修正后的完整代码片段：

@Configuration
class TopicConfiguration {

    private final KafkaConfigProperties configProperties;

    // 通过构造函数注入配置属性类（Spring推荐的注入方式）
    public TopicConfiguration(KafkaConfigProperties configProperties) {
        this.configProperties = configProperties;
    }

    private ConsumerFactory<String, String> createConsumer(String id) {
        Map<String, String> config = new HashMap<>();
        // 读取配置文件中的bootstrap servers
        config.put(ConsumerConfig.BOOTSTRAP_SERVER_CONFIG, configProperties.getBootstrapServers());
        // 补充其他必要的消费者配置
        config.put(ConsumerConfig.GROUP_ID_CONFIG, id);
        config.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
        config.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
        
        return new DefaultKafkaConsumerFactory<>(config);
    }
}

4. 验证配置读取是否正常

可以临时添加打印语句，确认读取到的配置值是否正确：

// 在createConsumer方法中添加
System.out.println("读取到的bootstrap servers: " + configProperties.getBootstrapServers());

如果输出为空或格式错误，检查配置文件路径是否正确（需放在resources目录下）、属性前缀是否与配置类的@ConfigurationProperties一致。

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