2016-02-15 118 views
4

有一些可以解釋這些文件在kafka代理日誌中的含義。在Kafka中解釋複製偏移量檢查點和恢復點偏移量

根@ a2md23297l:/ tmp目錄/卡夫卡日誌-1#貓恢復點偏移檢查點
我的話題0 0
kafkatopic_R2P1_1 0 0
我的話題1 0
kafkatopic_R2P1 0 0
試驗0 0
根@ a2md23297l:/ TMP /卡夫卡-日誌-1#貓複製偏移檢查點
我的話題0 0
kafkatopic_R2P1_1 0 2
我的話題1 0
kafkatopic_R2P1 0 2
試驗0 57

據透露,我的話題,kafkatopic_R2P1_1,我的話題,kafkatopic_R2P1,測試是創建的主題。 在此先感謝。

回答

5

AFAIK:recovery-point-offset-checkpoint是內部代理日誌,其中Kafka跟蹤哪些消息(從 - 到偏移量)已成功檢查到磁盤。

replication-offset-checkpoint是內部經紀人日誌,其中卡夫卡跟蹤哪些消息(從 - 抵消)被成功複製到其他經紀人。

欲瞭解更多詳情,你可以採取a deeper look在:kafka/core/src/main/scala/kafka/server/LogOffsetMetadata.scalaReplicaManager.scala。代碼評論相當不錯。

2

Marko是現貨。

開始兩個數字(0-不知道這是什麼)

號(即存在特定的磁盤分區的5號)旁邊的主題名稱(主題0-24分區號) 下一個數字是刷新到磁盤的偏移量(recovery-point-offset-checpoint)和複製偏​​移量檢查點上一次偏移量,副本已成功複製數據