在開始講解之前，先帶著大家回憶一下kafka一些名詞概念：

a. Broker：提供數(shù)據(jù)存儲和數(shù)據(jù)讀寫服務實例，一個Kafka節(jié)點就是一個broker，多個broker可以組成一個Kafka集群。

b. Topic：代表的是一類消息，例如應用日志的topic，應用健康監(jiān)控指標的topic等。

c. Partition：topic物理上的分組，一個topic可以分為多個partition。

d. Segment：partition物理上由多個segment組成，每個segment是一個文件。

e. offset：每個partition都由一系列有序的、不可變的消息組成，這些消息被連續(xù)的追加到partition中。partition中的每個消息都有一個連續(xù)的序列號叫做offset,用于partition唯一標識一條消息.

下面是兩個topic,頁面瀏覽流量日志的topic page_view，和點擊日志 click_log，在kafka數(shù)據(jù)目錄下的分區(qū)存儲情況：

|--page_view-0 
          |--page_view-1 
          |--page_view-2 
          |--page_view-3 
          |--click_log-0 
          |--click_log-1 
          |--click_log-2 
          |--click_log-3 

下圖說明了文件的存儲方式：

• 每個partion(目錄)相當于一個巨型文件被平均分配到多個大小相等segment(段)數(shù)據(jù)文件中。但每個段segment file消息數(shù)量不一定相等，這種特性方便old segment file快速被刪除。
• 每個partiton只需要支持順序讀寫就行了，segment文件生命周期由服務端配置參數(shù)決定。

這樣做的好處就是能快速刪除無用文件，有效提高磁盤利用率。

partition中segment file組成和物理結(jié)構(gòu)，細節(jié)如下：

• segment file組成：由2大部分組成，分別為index文件和data文件，這兩個文件一一對應，成對出現(xiàn)，后綴”.index”和“.log”分別表示為segment索引文件、數(shù)據(jù)文件.
• segment文件命名規(guī)則：partion全局的第一個segment從0開始，后續(xù)每個segment文件名為上一個segment文件最后一條消息的offset值。數(shù)值最大為64位long大小，19位數(shù)字字符長度，沒有數(shù)字用0填充。

創(chuàng)建一個topicXXX包含1 partition，設置每個segment大小為500MB,并啟動producer向Kafka broker寫入大量數(shù)據(jù)，該partition文件內(nèi)容如下：

圖1

還有一張細節(jié)的圖，說明一些index文件和log文件的對應關(guān)系：

圖2

索引文件存儲大量元數(shù)據(jù)，數(shù)據(jù)文件存儲大量消息，索引文件中元數(shù)據(jù)指向?qū)獢?shù)據(jù)文件中message的物理偏移地址。其中以索引文件中元數(shù)據(jù)3,497為例，依次在數(shù)據(jù)文件中表示第3個message(在全局partiton表示第368772個message)、以及該消息的物理偏移地址為497。

例如讀取offset=368776的message，需要通過下面2個步驟查找。

第一步查找segment file 以前面圖1為例，其中00000000000000000000.index表示最開始的文件，起始偏移量(offset)為0.第二個文件00000000000000368769.index的消息量起始偏移量為368770 = 368769 + 1.同樣，第三個文件00000000000000737337.index的起始偏移量為737338=737337 + 1，其他后續(xù)文件依次類推，以起始偏移量命名并排序這些文件，只要根據(jù)offset **二分查找**文件列表，就可以快速定位到具體文件。當offset=368776時定位到00000000000000368769.index|log

第二步 圖2 ，通過segment file查找message 通過第一步定位到segment file，當offset=368776時，依次定位到00000000000000368769.index的元數(shù)據(jù)物理位置和00000000000000368769.log的物理偏移地址，然后再通過00000000000000368769.log順序查找直到offset=368776為止。

這樣做的優(yōu)點很明顯，segment index file采取稀疏索引存儲方式，它減少索引文件大小，通過mmap可以直接內(nèi)存操作，稀疏索引為數(shù)據(jù)文件的每個對應message設置一個元數(shù)據(jù)指針,它比稠密索引節(jié)省了更多的存儲空間，但查找起來需要消耗更多的時間。

[[347742]]

本文轉(zhuǎn)載自微信公眾號「浪尖聊大數(shù)據(jù)」，可以通過以下二維碼關(guān)注。轉(zhuǎn)載本文請聯(lián)系浪尖聊大數(shù)據(jù)公眾號。