超时中断当前线程后Kafka Transactions未正常回滚问题

问题根因 #

• Spring声明式事务的默认回滚规则是仅当方法抛出未捕获的RuntimeException或Error时才会触发回滚。线程中断抛出的InterruptedException如果被业务代码/框架层捕获后吞掉、没有抛到事务切面层，事务会判定为执行正常，进而提交事务，导致已经发送的消息持久化到Kafka。
• 你使用的Kafka巡检工具大概率配置了isolation.level = read_uncommitted（读未提交），所以能看到还未提交/回滚的事务消息，正常业务消费者如果配置为read_committed（读已提交，默认值）是看不到未提交的消息的，事务回滚后这些临时消息会被Kafka自动清理。
• KafkaTemplate.send()是异步调用，返回ListenableFuture对象，即使线程被中断，已经触发的发送请求如果在事务提交前完成，只要事务最终被提交，消息就会被持久化。

修复方案 #

• 不要吞掉中断异常，捕获InterruptedException后需要重置中断标志并抛出运行时异常，让事务切面感知到异常触发回滚：

try {
    Thread.sleep(5000);
} catch (InterruptedException e) {
    Thread.currentThread().interrupt(); // 重置线程中断标志
    throw new RuntimeException("请求超时，事务终止", e); // 抛出异常触发事务回滚
}

• 调整@Transactional注解配置，明确指定回滚的异常类型，避免受默认回滚规则限制：

// 配置所有Exception类型异常都触发回滚
@Transactional(rollbackFor = Exception.class)

• 检查超时过滤器的中断逻辑，确保中断操作能让业务方法抛出异常终止，避免业务方法静默继续执行导致事务意外提交。
• 确认Kafka生产者配置的transactional.id属性已正确配置，且对应Kafka集群的事务功能正常开启。

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