如果消费者在 Chronicle 上失败会怎样

Question

您好，看看 Chronicle v3 如果消费者读取队列记录然后尝试对下游记录做某事但失败了会发生什么。

能否再次从队列中提取该记录？一切都需要重播吗？

考虑使用 Chronicle Queue 对一堆 json 文档进行排队并将它们批处理到 Elasticsearch :)

Answer 1

您需要存储成功处理的记录的索引，如：

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

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

然后在重新启动时您可以回到最后保存的索引：

tailer.index(savedIndex());