首先,明確幾個概念：

(1) Kafka運行在一個或多個服務(wù)器上,每個服務(wù)器被稱為Broker，主要用于存儲消息，但不需要維護offset偏移量。

(2) Kafka集群分類存儲的記錄流被稱為主題(Topics)。

(3) 每個消息記錄包含一個鍵，一個值和時間戳。

(4)（key與topic可以確定一個partition），此外可以通過制定partitioner分區(qū)器，進行計算到相關(guān)的分區(qū)節(jié)點上面，此外還可以通過相關(guān)的不同的算法進行設(shè)定。