Spring Boot集成Kafka时无法设置部分生产者配置问题

从你的描述和代码来看，retry.backoff.ms未按预期生效主要有几个核心原因，以下是针对性的排查和解决步骤：

1. YAML配置格式错误 #

你当前的application.yaml使用=定义键值对，不符合YAML语法规范，Spring无法正确解析该配置，导致@Value注入的是默认值30000；而日志显示retry.backoff.ms=1000，说明实际生效的生产者并非你自定义的实例。

修正后的YAML配置：

myApp:
  retry-backoff-ms: 50
  delivery-timeout-ms: 1000

2. 生产者Bean未被Spring容器管理 #

你的myAppProducer()方法没有添加@Bean注解，Spring不会将该方法创建的生产者实例纳入容器管理，实际业务中可能使用了Spring Boot自动配置的默认Kafka生产者，导致retry.backoff.ms被设置为其他值。

修正代码：

@Configuration
public class MyAppProducerConfig {

  @Value("${myApp.delivery-timeout-ms:#{120000}}")
  private int deliveryTimeoutMs;

  @Value("${myApp.retry-backoff-ms:#{30000}}")
  private int retryBackoffMs;

  // 添加@Bean注解，确保Spring使用该生产者实例
  @Bean
  Producer<MyKey, MyValue> myAppProducer() {
    Map<String, Object> config = new HashMap<>();
    config.put(org.apache.kafka.clients.producer.ProducerConfig.DELIVERY_TIMEOUT_MS_CONFIG, deliveryTimeoutMs);
    config.put(org.apache.kafka.clients.producer.ProducerConfig.RETRY_BACKOFF_MS_CONFIG, retryBackoffMs);
    // 无需自定义工厂，直接使用DefaultKafkaProducerFactory即可
    final var factory = new DefaultKafkaProducerFactory<MyKey, MyValue>(config);
    return factory.createProducer();
  }
}

3. 移除不必要的自定义KafkaProducerFactory #

你自定义的KafkaProducerFactory仅继承了DefaultKafkaProducerFactory且无任何自定义逻辑，直接使用原生工厂类即可，避免不必要的继承带来潜在问题。

4. 验证配置注入是否生效 #

可以在myAppProducer()方法中添加打印，确认retryBackoffMs是否正确读取到配置值：

@Bean
Producer<MyKey, MyValue> myAppProducer() {
  System.out.println("读取到的retry-backoff-ms值: " + retryBackoffMs);
  // 其余代码不变
}

如果打印值为50，说明配置注入正常，重启应用后即可看到retry.backoff.ms=50生效。

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