声明多个KafkaTransactionManager时事务报错，如何用注解解决？

当存在多个KafkaTransactionManager和标记了@Primary的JpaTransactionManager时，仅用@Transactional("kafkaStringTransactionManager")标记方法无法让KafkaTemplate识别到对应的Kafka事务，核心原因是：

• 单个KafkaTransactionManager存在时，KafkaTemplate会自动匹配唯一的同类型事务管理器；
• 多个KafkaTransactionManager共存时，KafkaTemplate无法自动确定要绑定的事务管理器，必须显式关联，否则即便通过注解开启了Kafka事务，模板也无法感知到该事务上下文。

需要将每个KafkaTemplate与对应的KafkaTransactionManager显式绑定，同时确保@Transactional指定的事务管理器与模板绑定的实例一致。

1. 配置阶段：绑定KafkaTemplate与事务管理器 #

在配置KafkaTemplate的Bean时，通过setTransactionManager()方法指定对应的KafkaTransactionManager：

// 第一个Kafka事务管理器
@Bean
public KafkaTransactionManager<String, String> kafkaStringTransactionManager(ProducerFactory<String, String> stringProducerFactory) {
    return new KafkaTransactionManager<>(stringProducerFactory);
}

// 绑定对应事务管理器的KafkaTemplate
@Bean
public KafkaTemplate<String, String> kafkaStringTemplate(ProducerFactory<String, String> stringProducerFactory,
                                                        KafkaTransactionManager<String, String> kafkaStringTransactionManager) {
    KafkaTemplate<String, String> template = new KafkaTemplate<>(stringProducerFactory);
    template.setTransactionManager(kafkaStringTransactionManager); // 显式绑定
    return template;
}

// 第二个Kafka事务管理器及对应Template的配置同理
@Bean
public KafkaTransactionManager<String, Object> kafkaObjectTransactionManager(ProducerFactory<String, Object> objectProducerFactory) {
    return new KafkaTransactionManager<>(objectProducerFactory);
}

@Bean
public KafkaTemplate<String, Object> kafkaObjectTemplate(ProducerFactory<String, Object> objectProducerFactory,
                                                        KafkaTransactionManager<String, Object> kafkaObjectTransactionManager) {
    KafkaTemplate<String, Object> template = new KafkaTemplate<>(objectProducerFactory);
    template.setTransactionManager(kafkaObjectTransactionManager);
    return template;
}

// 保持JPA事务管理器为默认主事务管理器
@Primary
@Bean
public JpaTransactionManager jpaTransactionManager(EntityManagerFactory entityManagerFactory) {
    return new JpaTransactionManager(entityManagerFactory);
}

2. 业务代码阶段：用@Transactional指定对应事务管理器 #

在需要使用Kafka事务的方法上，指定对应的事务管理器名称，同时确保调用的是绑定了该管理器的KafkaTemplate：

@Service
public class KafkaMessageService {

    private final KafkaTemplate<String, String> kafkaStringTemplate;

    // 注入绑定了kafkaStringTransactionManager的模板实例
    public KafkaMessageService(KafkaTemplate<String, String> kafkaStringTemplate) {
        this.kafkaStringTemplate = kafkaStringTemplate;
    }

    // 指定使用kafkaStringTransactionManager开启事务
    @Transactional("kafkaStringTransactionManager")
    public void sendStringMessage(String topic, String message) {
        kafkaStringTemplate.send(topic, message);
    }
}

额外注意点 #

• 避免同一类内部调用@Transactional标记的方法：Spring事务基于代理实现，内部调用会绕过代理逻辑，导致事务不生效。若需内部调用，可通过注入自身Bean或AopContext.currentProxy()获取代理对象执行方法。
• 确认事务管理器名称与Bean名称一致：如果@Bean未指定名称，默认使用方法名作为Bean名称，需保证@Transactional的value值与之一致。

内容的提问来源于stack exchange，提问作者HyoD.k