Spring引导属性yaml

Question

我使用自动配置（仅通过注释）运行Spring启动和kafka，并在.yaml文件中定义了道具，即：

spring:
  kafka:
    bootstrap-servers: someserver:9999
    consumer:
      group-id: mygroup
....

 @KafkaListener()
  public void receive(ConsumerRecord<?, ?> consumerRecord) {
....
  }

它工作得很好，spring maps即字段group-id正确。

但是当我尝试使用相同的yaml文件手动配置Kafka（使用消费者工厂和消费者配置）时，我遇到了问题。在类中，消费者配置Kafka属性以 命名。在名称中，而不是 _ 即：

public static final String GROUP_ID_CONFIG = "group.id";

所以我不能把它们加载到map中，然后把map传递给ConsumerFactory，因为键是with _ not。

我不想像Spring kafka团队提供的例子那样丑陋，当他们将道具从yaml映射到配置类，然后手动分配地图中的道具以传递给工厂时：

@ConfigurationProperties(prefix = "kafka")
public class ConfigProperties {

    private String brokerAddress;

    private String topic;

    private String fooTopic;

    public String getBrokerAddress() {
        return this.brokerAddress;
    }

.....

    @Bean
    public ProducerFactory<String, String> producerFactory() {
        Map<String, Object> props = new HashMap<>();
        props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, this.configProperties.getBrokerAddress());
    .....

        return new DefaultKafkaProducerFactory<>(props);
    }

Answer 1

如果您想使用yml文件中的虚线属性，您需要像引导一样对不直接支持作为引导属性的任意属性进行操作：

spring:
  kafka:
    consumer:
      properties:
        group.id: foo

即填充属性属性。

boot为某些属性提供第一类支持的原因是，IDE编辑器可以提供内容辅助，这对于任意属性是不可能的。