node-kafka-consumerをoffsetOutOfRangeで停止する必要がありますか？

Question

私はnode-kafkaコンシューマを書きました。まれに、kafkaクライアントを、特定のオフセットが利用可能であったが使用できなくなったために使用されたgroup-idで開始します。これにより、「offsetOutOfRange」イベントが呼び出されます。 この場合、推奨される動作は何ですか？エラーを記録して終了しますか？回復する方法はありますか？私はいつも、最後にコミットされたオフセット（存在していれば使用可能な場合）から飼い猫を走らせたい。

Answer 1

これは、ノード・カフカ、消費者には実装されていない理由を私は疑問に思うが、他のクライアントには、範囲エラーのうち、オフセット処理するためのデフォルトの動作は、オフセット可能な最早または最新のいずれかを取得するためにOffsetRequestを発行することですコンシューマオフセットを新しい値に設定してフェッチを続行します。

これは完全にリカバリ可能な状況であり、リカバリするオフセットを指定する必要があります。