首页 > 试题广场 >

为了实现跨多个 Topic-Partition 的精准一次(

[单选题]
为了实现跨多个 Topic-Partition 的精准一次(Exactly-Once Semantics, EOS)消息处理,Kafka 引入了事务机制。当一个 Producer 提交一个事务时,Transaction Coordinator 的核心职责是什么?
  • 它会为该事务涉及的所有分区加锁,在写入事务控制消息(COMMIT/ABORT)期间,阻止其他 Producer 和 Consumer 的读写操作。
  • 它主要负责管理 Producer 的 Producer ID (PID) 和序列号,依靠幂等性来保证跨分区的事务。
  • 它负责管理事务状态,将事务日志(如 BEGIN, PREPARE_COMMIT, COMPLETE_COMMIT)写入内部的 `__transaction_state` 主题,并最终向目标数据 Topic 的分区写入事务标记(Transaction Marker)。
  • 它会绕过 Page Cache,直接将事务消息和数据消息同步刷写到磁盘,以确保事务的原子性和持久性。
A是防止并发问题,而数据的插入是不涉及并发问题的(没有共享资源的访问)。总之,事务是事务,并发是并发
发表于 今天 12:40:34 回复(0)