RocketMQ has already supported distributed transaction messages since version 4.3.0. It implements transaction messages using the concept of 2PC. Meanwhile, it has added compensation logic to handle the messages that timeout or fail in the second phase

the process of transaction message as below: