Kafka之消費信息保存在哪


了消費位移對應的消息內容格式,上面是消息的 key ,下面是消息的 value
可以看到 key value 中都包含了 version 宇段,這個用來標識具體的 key value 的版本信
息,不同的版本對應的內容格式可能並不相同 。就目前版本而言, key 和 value的 version
都為1。 key 中除了 version 字段還有 group、topic、partition 字段,分別表示消費組
groupId、主題名稱和分區編號。雖然 key 中包含了4 個字段,但最終確定這條消息所要存儲
的分區還是根據單獨的 group 字段來計算的,這樣就可以保證消費位移信息與消費組對應的
GroupCoordinator 處於同一個 broker 節點上,省去了中間輪轉的開銷,這一點與消費組的元數
據信息的存儲是一樣的
  
 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM