2017-08-16 46 views
0

與壓縮主題相關的問題。在一個緊湊的主題中,當日志清理器清理特定鍵的先前偏移量(3,4,5)(假設5是最新的偏移量)時有延遲,而將消耗這些偏移量作爲消費者使用時,我只會看到該密鑰的最新偏移量(5)即使當3和4還沒有被壓縮或者消費者將按照該順序得到(3,4,5)?壓縮主題:日誌清理和消耗抵消

回答

1

如果3和4還沒有壓縮出主題,您的消費者將得到(3,4,5)。如果您訂閱3時是最新消息,那麼您將得到相同的結果,然後4和5後來發佈,因此它不應該打破您的消費者邏輯。此外,壓縮不會在每個主題分區的最新部分上運行,因爲這些分段文件仍處於打開狀態以供寫入。這意味着不能保證每個密鑰只存在於一條消息中。