我正在使用springboot开发一个微服务架构。我的一个应用程序扮演Kafka制作人的角色，写Kafka主题的日志。我的生产者配置如下：

@Configuration
public class KafkaProducerConfig {
@Value("${kafka.address:X.X.X.X:9092}")
private String bootstrapAddress;
@Bean
public ProducerFactory<String, KafkaTopicMessage> producerFactory() {
    Map<String, Object> configProps = new HashMap<>();

    configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapAddress);
    configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringOrBytesSerializer.class);
    configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);

    return new DefaultKafkaProducerFactory<>(configProps);
}

@Bean
public KafkaTemplate<String, KafkaTopicMessage> kafkaTemplate() {
    return new KafkaTemplate<>(producerFactory());
}
}

另外，我的主题是：

@Configuration
public class KafkaTopicConfig {

@Value("${kafka.address:X.X.X.X:9092}")
private String bootstrapAddress;

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

@Bean
public NewTopic logTopic() {
    return new NewTopic("log-topic", 1, (short) 1);
}
}

另一个应用程序正在使用这个主题。我的消费者配置如下：

@EnableKafka
@Configuration
public class KafkaConsumerConfig {

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

@Bean
public ConsumerFactory<String, KafkaTopicMessage> consumerFactory() {
    Map<String, Object> props = new HashMap<>();
    props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "X.X.X.X:9092");
    props.put(ConsumerConfig.GROUP_ID_CONFIG, "log");
    props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
    props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, JsonDeserializer.class);
    return new DefaultKafkaConsumerFactory<>(props);
}

}

我还包括了configuration application.yml文件。这样地：

kafka:
address: X.X.X.X:9092

spring:
    kafka:
        consumer:
            bootstrap-servers: ${kafka.address}
            group-id: log
            auto-offset-reset: earliest
            key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
        value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
        properties:
            spring:
                json:
                    trusted:
                        packages: '*'
    producer:
        bootstrap-servers: ${kafka.address}
        key-serializer: org.apache.kafka.common.serialization.StringSerializer
        value-serializer: org.springframework.kafka.support.serializer.JsonSerializer

问题是，即使我明确给出了我的服务器地址，它也在尝试连接到 127.0.0.1:9092 . 有人能帮我解决这个问题吗？为什么它不读取我的配置，为什么它会有一个默认配置？我感谢你的帮助。