在Apache Kafka与RDBMS中，不依赖第三方库用给定代码实现原子性是否为最佳实践？

问题背景（翻译后） #

已知两阶段提交（2PC）、Outbox模式的概念，但不想使用Atomiko这类第三方库，请问以下代码是不是实现原子性的良好实践？

@Transactional
public void testTransaction() {
    try {
        // 假设这里已创建obj对象
        myRepository.save(obj);

        // 下面这样捕获数据库异常可行吗？
        entityManager.flush();

        // 发送消息
        kafkaTemplate.executeInTransaction(k -> {
            k.send("topic-1", "msg");
            k.send("topic-2", "msg");
            k.send("topic-3", "msg");
            return null;
        });
    } catch (Exception e) {
        throw e;
    }
}

核心问题分析 #

这段代码无法保证数据库数据持久化和Kafka消息发送的原子性，必然存在数据不一致的风险：

• 代码中的@Transactional是数据库本地事务，而kafkaTemplate.executeInTransaction是Kafka自身的事务，两者完全独立，没有协调机制：
  1. 如果数据库事务提交成功，但Kafka事务提交失败：数据库里已经有了obj的数据，但消息没发出去，业务会丢失关键事件；
  2. 如果Kafka事务提交成功，但数据库事务后续回滚：消息已经进入Kafka，但数据库里的obj并未保存，消费端处理消息时会找不到对应数据，引发业务异常。
• 你添加的entityManager.flush()只是将JPA持久化上下文的变更刷到数据库，但此时数据库事务并未提交，这步操作解决不了跨系统的原子性问题。

无第三方库的原子性实现方案 #

既然你了解Outbox模式，这就是最适合的轻量方案，无需依赖分布式事务框架：

1. 新增一张outbox表，核心字段包括：消息ID、主题、消息内容、状态（待发送/已发送/发送失败）、创建时间；
2. 在同一个数据库事务中，同时完成业务对象obj的保存和Outbox消息记录的插入；
3. 编写独立的后台任务（比如定时任务、异步线程），轮询outbox表中状态为「待发送」的消息；
4. 调用KafkaTemplate发送消息，发送成功后将消息状态更新为「已发送」；发送失败则标记为「发送失败」，并设置重试机制（比如固定次数重试，超过后触发告警人工介入）。

这种方案利用本地事务保证业务数据与消息记录的原子性，通过异步重试解决消息发送的可靠性问题，完全规避了分布式事务的复杂度。

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