kafka事务处理流程
2025-02-23 13:28:42 0 举报kafka开启事务机制后的内部处理机制
作者其他创作
大纲/内容
success
1、FIND_COORDINATOR查找事务管理器所在节点
Leader
2、txId.hashCode % 50事务有50个分区，通过事务ID取模得到分区ID
11、修改事务状态为CompleteCommit
9、修改事务状态为PrepareCommit
Producer
8、END_TXN结束事务(告诉kafka提交事务)
Broker
6、ADD_PARTITIONS_TO_TXN提交保存成功的数据分区信息
10、WRITE_TXN_MARKERS写入事务标记：成功或失败
_transaction_state
3、INIT_PRODUCER_ID初始化生产者ID
5、PRODUCE生产数据
TransactionCoordinator
4、ADD_PARTITIONS_TO_TXN将数据的分区信息传送给事务管理器
7、ACKS应答响应机制
收藏
0 条评论
下一页
