chronicle - Chronicle で消費者が失敗した場合はどうなりますか

Question

こんにちは Chronicle v3 を見てください。コンシューマがキューのレコードを読み取り、そのレコードをダウンストリームで処理しようとして失敗した場合はどうなりますか。

そのレコードを再びキューから取得できますか? すべてを再生する必要がありますか?

Chronicle Queue を使用して一連の json ドキュメントをキューに入れ、それらを Elasticsearch にバッチ処理することを考えています :)

Answer 1

You need either to store the index of the record successfully processed like:

if(tailer.nextIndex()) {
    process(tailer);

    saveIndex(tailer.index());
    tailer.finish(); 
}

Then upon restart you can wind to the last saved index:

tailer.index(savedIndex());