我想知道，當startOffsetTime的值是kafka.api.OffsetRequest.EarliestTime（）。偏移值是什麼？

Question

當我設置​​時，偏移值是可用的最大值。

設置時startOffsetTime is kafka.api.OffsetRequest.EarliestTime()補償值是多少？

Answer 1

很難理解你的問題。但無論如何，我想你問的是，當你查詢最早的偏移量時將會出現什麼偏移量。

Kafka具有日誌保留配置，允許爲消息或日誌文件大小設置生存時間。 More here。

想象一下，你有設置爲1小時日誌保留時間的話題和你產生一些消息與以下偏移：

0 1 2 3 4 5 6 7 8 9 10 ... 

一小時後舊郵件將從日誌被刪除，您可能會得到如下圖：

<offsets 0 1 2 3 4 no more exist in log> 5 6 7 8 9 10 ... 

然後當你會爲最早的查詢抵消你會得到5作爲補償0-4不再存在。

這同樣適用於log.retention.bytes配置，當您超過配置值時，舊的消息將被丟棄（實際上是整個段，但這對此問題無關緊要），導致最早的偏移量高於0。