它会为该事务涉及的所有分区加锁,在写入事务控制消息(COMMIT/ABORT)期间,阻止其他 Producer 和 Consumer 的读写操作。
它主要负责管理 Producer 的 Producer ID (PID) 和序列号,依靠幂等性来保证跨分区的事务。
它负责管理事务状态,将事务日志(如 BEGIN, PREPARE_COMMIT, COMPLETE_COMMIT)写入内部的 `__transaction_state` 主题,并最终向目标数据 Topic 的分区写入事务标记(Transaction Marker)。
它会绕过 Page Cache,直接将事务消息和数据消息同步刷写到磁盘,以确保事务的原子性和持久性。