[metaq]Consumer

Metaq是一個類是kafka的消息系統,開源地址https://github.com/killme2008/Metamorphosis。 基於Pull的消息系統,consumer端保持了很多邏輯,比如當前拉取消息的offset,loadbalance等,使用zookeeper作爲coordination。 簡單類圖 核心類ZKLoadRebalanceListener,負責集羣感知,當有brok
相關文章
相關標籤/搜索
本站公眾號
   歡迎關注本站公眾號,獲取更多信息