Q

卡夫卡保留期後的偏移量

2016-10-25 83 views 4 likes

4

我有1個分區的卡夫卡主題。如果它有100條消息，它的偏移量將從0.99。卡夫卡保留期後的偏移量

根據kafka保留策略，所有消息將在指定的時間段後被清除。

一旦所有消息都已被清除（保留期限後），我將向該主題發送100條新消息。現在，消息的新偏移從何處開始？是從100還是從0？

我想了解新的補償是100-199還是0-99？

2016-10-25 AKC

A

回答

6

Kafka通過刪除符合謂詞的日誌段來紀念日誌保留策略，它永遠不會刪除活動日誌段，這意味着活動日誌段的基址偏移將始終保持不變。

至於你的例子，如果第一批100條消息都在同一個日誌段中，Kafka將創建一個基準偏移量爲100的新日誌段，並在日誌保留期限後刪除舊段的時間過去了。所以一條新消息的起始偏移量爲100.

2016-10-25 23:29:14 amethystic

+0

謝謝。這很有幫助。 – AKC

相關問題