Kafka 事务消息中 transactional.id、事务协调器与隔离级别如何共同定义消息可见性？

我会把它拆成三层来理解：transactional.id 定义事务身份，事务协调器维护事务状态并驱动提交结果落盘，消费者的 isolation.level 决定最终能看到哪些消息。

1. transactional.id：确定事务身份

transactional.id 是生产者的逻辑身份。生产者调用 initTransactions 时，Kafka 会根据这个 ID 找到对应的事务协调器，并分配或恢复 Producer ID 和 epoch。

同一个 transactional.id 只能由一个有效的生产者实例使用。如果实例重启或发生重复启动，新的 epoch 会使旧生产者被 fencing，避免两个实例同时使用同一个事务身份写入数据。因此它通常需要在实例重启后保持稳定，但不同并发实例之间必须唯一。

不过，配置了 transactional.id 并不代表消息自动处于事务中，必须在 beginTransaction 和 commitTransaction 或 abortTransaction 之间发送消息。

2. 事务协调器