生产者端Kafka事务管理问询：事务回滚时消息是否会被回滚

基础机制回答 #

首先直接回应你的核心疑问：Kafka 从0.11版本开始原生支持生产者事务能力，和你熟悉的JMS事务机制逻辑完全一致：

• 事务内发送的所有消息，只有在生产者主动提交事务之后才会对配置了读已提交隔离级别的消费者可见，未提交的消息不会被正常消费。
• 当事务触发回滚时，Kafka服务端会直接标记本次事务内的所有消息为无效，不会对外暴露，等价于实现了消息层面的回滚效果，不需要额外做消息删除、补偿操作。

注意：事务模式下的消息回滚是Kafka原生能力，并非写入后再删除，未提交的事务消息本身就不会被标记为可消费状态，回滚操作只是将这部分临时存储的消息标记为无效即可。

结合Oracle事务的业务场景表现 #

你当前的业务是在同一个事务内包含Oracle数据库插入、Kafka消息发送两个操作，只要配置正确，两者的事务状态是完全绑定的：

• 当业务逻辑触发事务回滚时，Oracle的插入变更会被撤销，同时Kafka生产者的事务也会同步触发回滚，本次事务内发送的所有Kafka消息都会被Kafka服务端清理，消费者完全收不到这些消息。
• 只有当整个事务完全提交时，Oracle的变更永久生效，Kafka的消息也会被正式提交到对应分区，对消费者可见。

Spring Boot 集成核心配置要求 #

要实现上述绑定效果，你需要做几个关键配置：

1. 基础配置项，在application.yml或application.properties中添加：

spring:
  kafka:
    producer:
      # 开启事务必须配置事务ID前缀
      transaction-id-prefix: your-business-tx-
      # 事务模式下必须配置acks为all，保证消息不丢失
      acks: all
    properties:
      # 幂等性是开启事务的前置要求，必须开启
      enable.idempotence: true
  # 你的Oracle数据源、JPA等原有配置保持不变

2. 事务管理器配置：如果需要同时管控Oracle（JPA/JDBC）和Kafka的事务，需要配置ChainedTransactionManager，将JPA事务管理器和Kafka事务管理器按顺序组合，保证两个事务的提交、回滚操作绑定。
3. 业务方法配置：在需要开启组合事务的方法上添加@Transactional注解即可。

注意事项 #

• 消费者端必须配置isolation.level为read_committed，才会过滤掉未提交/已回滚的事务消息，默认值read_uncommitted下消费者可以读到未提交的消息，不符合你的业务要求。
• 只有显式开启事务模式的Kafka生产者才支持消息回滚，普通无事务模式下消息发送后直接写入分区，没有回滚能力。

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