kafka HA
2019-09-12 09:54:04 0 举报
登录查看完整内容
kafka HA实现
作者其他创作
大纲/内容
Broker进程
Machine 1
从master node读读取具体数据
Machine 7
Machine 2
msg1
Machine 8
Machine 5
从master node 读取 msg3
Machine 4
3. replica线程周期同步master数据
Machine 9
topic [t1]partition 1Replica2
Machine 6
从master node读取msg2
topic [t1]partition 2Replica2
topic [t1]partition 2Replica1
1.写入msg3
topic [t1]partition 2Replica3
topic [t1]partition 3Replica3
2.持久化
Consumer
1.写入msg1
topic [t1]partition 3Replica1
生产者（向topic t1 写入三条消息）
topic [t1]partition 1Replica3
topic [t1]partition 1Replica1
topic [t1]partition 3Replica2
Machine 3
ISR(In-Sync replicas) 维护者所有与leader数据差异在阈值范围内的副本所在的borker id列表
4. 同步msg1
职业：暂无
0 条评论
回复 删除
下一页
