如何创建单事务Kafka生产者？Spring Boot如何使用单实例生产者？

核心配置方案 #

当通过transactionIdPrefix启用事务时，Spring Kafka默认会维护生产者缓存以复用实例。要强制使用单个生产者，可通过以下两种方式实现：

1. 限制生产者缓存容量 #

直接通过Spring Boot配置文件设置缓存大小为1，这样缓存中只会保留一个生产者实例，所有事务都会复用它：

# application.properties
spring.kafka.producer.cache.size=1

2. 统一事务ID分区策略 #

默认情况下，Spring Kafka会根据事务ID的哈希值分配生产者，即使缓存大小为1，也可能因哈希逻辑创建新实例。可自定义ProducerFactory，将事务ID分区数设为1，确保所有事务绑定同一个生产者：

@Bean
public ProducerFactory<String, Object> producerFactory() {
    Map<String, Object> configProps = new HashMap<>();
    configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "你的Kafka地址");
    // 其他生产者基础配置
    DefaultKafkaProducerFactory<String, Object> factory = new DefaultKafkaProducerFactory<>(configProps);
    factory.setTransactionIdPrefix("tx-prefix-");
    // 设置分区数为1，强制所有事务使用同一个生产者
    factory.setTransactionIdPartitionCount(1);
    return factory;
}

无事务场景的简化处理 #

如果业务不需要事务支持，直接移除transactionIdPrefix配置即可。此时Spring Kafka默认会使用单个生产者实例（除非显式配置了缓存），无需额外调整。

验证方式 #

开启org.springframework.kafka.core.DefaultKafkaProducerFactory的DEBUG日志，观察日志输出中生产者实例的创建次数，确认仅初始化了一个实例。

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