Kafka图解
?
?
?
?
?
?
?
?
?
?
?
?
?類似于公眾號(hào)訂閱
?
缺點(diǎn)；消費(fèi)者主動(dòng)拉取的模式中，消費(fèi)者主動(dòng)輪詢隊(duì)列有沒(méi)有消息
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
1：同一個(gè)組的消費(fèi)者，不能消費(fèi)同一個(gè)分區(qū)的數(shù)據(jù)
例如consumer A 和 consume B 是同一個(gè)組的，他們兩不能消費(fèi)Partition 0 的數(shù)據(jù)
2：讀寫(xiě)數(shù)據(jù)之能從Leader上，Follow只能做備份
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
ack機(jī)制
所有的followers都備份完了，都寫(xiě)入成功了
followers給leader法施工ack應(yīng)答
然后leader會(huì)給producer
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
.log文件是保存數(shù)據(jù)的
.index是保存offset位置的
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
總結(jié)
- 上一篇： pip show pip可以查看pip的
- 下一篇： 关于使用NLPIR-ICTCLAS分词系