Wha happens if consumer fails on Chronicle

Question

Hi looking at Chronicle v3 what happens if the consumer reads a record of the queue then tries to do something with that record downstream but fails.

Can that record be picked up from the queue again? Does everything need to be replayed?

Thinking of using Chronicle Queue to queue a bunch of json documents and batch them to 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());