AI
推荐
模板社区
专题
登录
免费注册
首页
流程图
详情
KafKa生产者事务
2023-06-18 17:37:14
5
举报
分享方式
免费使用
KafKa生产者事务
消息中间件
模版推荐
作者其他创作
大纲/内容
4.发送commit请求
Kafka cluster
3.发送消息到TopicA
默认50个分区，每个分区负责一部分事务，其划分根据transactional.id的hashcode值%50，计算出该事务属于哪个分区，该分区Leader副本所在的broker节点即为这个transactional.id的Transaction Coordinator节点
8.返回成功
TopicA-Partition()Leader
2.返回producer id
TransactionCoordinator事务协调器
__transaction_state-分区-Leader存储事务信息的特殊主题
9
broker0
8
1.请求producer id(幂等性需要)
6.返回成功
KafkaProducer
7
7.后台发送commit请求
broker1
5.持久化commit请求
9.持久化事务成功信息
收藏
立即使用
消费者组详细消费流程
收藏
立即使用
kafka消费者工作流程
收藏
立即使用
KafkaLeader选举工作流程
收藏
立即使用
KafKa生产者事务
PO_595203
职业：暂无
去主页
Collect
Get Started
Kafka生产者流程
Collect
Get Started
生产者-消费者
Collect
Get Started
Kafka生产者流程
Collect
Get Started
kafka生产者消费者模型
评论
0
条评论
下一页
Document
