我應該在offsetOutOfRange上停止我的node-kafka-consumer嗎？

Question

我寫了一個節點卡夫卡消費者。在極少數情況下，我使用一組group-id啓動kafka客戶端，當某些偏移量可用時使用該組ID，但不再可用 - 導致調用「offsetOutOfRange」事件。 這種情況下推薦的行爲是什麼？記錄錯誤並退出？有沒有辦法恢復？我總是希望從上次提交的偏移量（如果存在並可用）運行zookeeper。

Answer 1

我不知道爲什麼，這是不是在節點卡夫卡消費者實現，但在其他客戶端處理偏移超出範圍錯誤的默認行爲是發出OffsetRequest讓無論是最早或最新的偏移量，然後將消費者偏移量設置爲新值並繼續提取。

這是一個完全可恢復的情況，您只需指定要恢復的偏移量 - 最早或最新可用。