1.概念 1.LEO(last end offset) 當(dāng)前replica存的當(dāng)前最大offset的下一個值 2.HW(high watermark) : 小于 HW值得of...
![240](https://upload.jianshu.io/users/upload_avatars/27560660/ddaa968c-6bb1-4a11-8788-a9c5c2c2ee92.jpg?imageMogr2/auto-orient/strip|imageView2/1/w/240/h/240)
1.概念 1.LEO(last end offset) 當(dāng)前replica存的當(dāng)前最大offset的下一個值 2.HW(high watermark) : 小于 HW值得of...
1.概念 1.AR(Assigned Repllicas):一個分區(qū)里面所有的副本(不區(qū)分leader和follower) 2.ISR(In-Sync Replicas):能...
1.kafka怎么避免重復(fù)消費? 答:利用兩階段事務(wù)提交或者容器去重(Hash Set庐冯、布隆過濾器格二、Redis) 2.Kafka怎么保證順序消費? 答:kafka是全有無序,...
1.消息系統(tǒng) 1.1消息系統(tǒng)/消息隊列作用 1.應(yīng)用解耦:多個應(yīng)用可以通過消息隊列來處理消息,應(yīng)用相互獨立,互不影響轨奄。 2.異步處理:比串行和并行處理,異步處理可以減少時間,...
1雌桑、配置每臺虛擬機主機名: 分別編輯每臺虛擬機的hostname文件妇菱,直接填寫主機名呛占,保存退出即可 vim /etc/hostname 第一臺主機主機名為:node1 第二臺...
三臺服務(wù)器部署 node1 node2 node3 (根據(jù)自己情況而定) 1.下載zookeeper壓縮包 http://archive.apache.org/dist/zo...
1.Zab協(xié)議概念: Zab協(xié)議全稱是 Zookeeper Atomic BroadCast (Zookeeper 原子廣播),Zookeeper是通過Zab協(xié)議來保證分布式...
1.Zookeeper Watcher(監(jiān)聽機制) Zookeeper 提供了分布式 數(shù)據(jù)發(fā)布和訂閱功能,一個典型的發(fā)布和訂閱模型系統(tǒng)定義了一種一對多的訂閱關(guān)系,能讓多個訂閱...
1.Zookeeper概念 1.zookeeper是一個分布式協(xié)調(diào)開源框架河泳。 2.zookeeper本質(zhì)上是一個小文件存儲系統(tǒng)沃呢。 2.Zookeeper特性 1.全局?jǐn)?shù)據(jù)一致...