请阐述 Kafka 中事务机制的底层实现原理，并解释该机制具体通过哪些步骤和组件来确保消息的一致性？

回答思路

1. 【回答框架 1】Kafka 事务机制的核心是引入事务协调器（Transaction Coordinator）和事务日志（Transaction Log），配合生产者端的幂等性（Idempotence）以及消费者端的隔离级别（read_committed）来共同实现跨分区的原子写入。
2. 【回答框架 2】事务实现的关键在于生产者必须开启 enable.idempotence=true，并指定 transactional.id。生产者通过 InitPidRequest 向协调器获取 PID 和 Epoch，之后每个分区写入前都需要注册分区到协调器，协调器将状态记录在事务日志中，以支持跨分区的原子性。
3. 【回答框架 3】事务提交流程涉及 PrepareCommit 和 Commit 等步骤：生产者发送 OffsetCommit 请求提交消费位点，并发送 EndTxn 请求给协调器，协调器先写入 PrepareCommit 标记，再向所有参与分区写入控制消息（COMMIT），最后更新事务状态为 CompleteCommit；如果发生中止则写入 PrepareAbort 和 ABORT 控制消息。
4. 【回答框架 4】为保证一致性，消费者必须设置 isolation.level=read_committed，这样 broker 会过滤掉未提交的事务消息，并等待事务完成后再返回数据；同时，协调器会缓存事务未完成的消息，直到收到提交或中止标记，从而保证消费者只能读取已提交的数据。
5. 【关键点 1】事务机制依赖事务协调器、事务日志、控制消息和生产者幂等性共同实现。
6. 【关键点 2】事务保证跨分区原子写入，通过 EndTxn 请求触发二阶段提交（PrepareCommit/Commit）。
7. 【关键点 3】消费者设置为 read_committed 隔离级别后才能读取已提交事务消息。
8. 【关键点 4】事务日志存储在内部主题 __transaction_state 中，用于记录事务状态和元数据。
9. 【关键点 5】如果发生故障，协调器通过事务日志恢复状态，进行超时回滚或继续提交。
10. 【易错点 1】容易混淆事务机制与幂等性，幂等性只保证单分区内无重复，事务机制解决跨分区原子性。
11. 【易错点 2】可能忽视隔离级别的重要性，若消费者使用 read_uncommitted，则仍会读到未提交的消息。
12. 【易错点 3】事务开启必须设置 transactional.id 且不能复用同一个 transactional.id 并发写入多个生产者实例。