问个分布式事务的问题

[7911364440]

业务流程大概是这样，从 RocketMQ 消费消息，将收到的数据转发给多个数据源（可能是 MySQL 、Oracle 、Kafka 等）。
问题是如何保证一条消息最终成功发送给所有客户端？假设写 MySQL 成功了，发送 Kafka 时失败了，要怎么重发？

目前想到的方案：

1. 将发送失败的消息保存到本地数据库，同时记录目标客户端，再通过定时任务重发。
2. 跟 1 类似，将失败的消息发送到消息队列中的某个特定的 topic ，客户端消费这个 topic 实现重发。

[documentzhangx66]

最省事的办法，是反向操作。

需要全局一致性的数据，全部放在关系型数据库里处理，此数据库用于全局专门处理这类数据。这种设计设计，性能、备份、HA 都很好做。

[xiaohundun]

是不是可以参考 seata 的 TCC 模式？

[candafromcn]

RocketMQ 不能像 kafka 一样分组消费吗，每一个需要同步的数据源认为是一个消费者，保证每个消费者 at least once 的消费就行了