Spring Boot 2.7.2集成Spring Kafka启用事务前缀启动失败问题

这不是Bug，是自定义ProducerFactory时的配置绑定逻辑导致的问题。

问题原因 #

Spring Boot自动配置的ProducerFactory会通过KafkaProperties自动读取配置文件中的所有生产者属性（包括transaction-id-prefix），并自动开启事务支持。但当你自定义ProducerFactory Bean时，默认不会自动关联这些配置属性，所以配置文件里的transaction-id-prefix无法生效，而Spring检测到配置了事务前缀但ProducerFactory未开启事务支持，就会抛出IllegalArgumentException: The 'ProducerFactory' must support transactions异常。

解决方案 #

方案1：使用@ConfigurationProperties自动绑定配置

给自定义的ProducerFactory Bean添加@ConfigurationProperties注解，指定前缀为spring.kafka.producer，让配置文件中的所有生产者属性自动注入到ProducerFactory中：

@Bean
@ConfigurationProperties(prefix = "spring.kafka.producer")
public ProducerFactory<String, Object> producerFactory() {
    return new DefaultKafkaProducerFactory<>(new HashMap<>());
}

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

这样application.yaml中的spring.kafka.producer.transaction-id-prefix就能被自动识别，DefaultKafkaProducerFactory会根据该配置自动开启事务支持。

方案2：手动注入事务前缀配置

如果不想使用@ConfigurationProperties，可以通过@Value直接注入配置文件中的事务前缀，手动设置到ProducerFactory的配置中：

@Bean
public ProducerFactory<String, Object> producerFactory(
        @Value("${spring.kafka.producer.transaction-id-prefix:}") String transactionIdPrefix) {
    Map<String, Object> configs = new HashMap<>();
    // 其他生产者配置也可通过@Value或KafkaProperties注入
    if (!transactionIdPrefix.isEmpty()) {
        configs.put(ProducerConfig.TRANSACTIONAL_ID_CONFIG, transactionIdPrefix);
    }
    return new DefaultKafkaProducerFactory<>(configs);
}

补充说明 #

如果你的场景不需要自定义ProducerFactory，建议直接使用Spring Boot的自动配置，这样所有配置文件中的属性都会自动生效，无需手动编写Bean。

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