chronicle - 如果消费者在 Chronicle 上失败会发生什么

Question

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

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

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

Answer 1

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

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

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

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

tailer.index(savedIndex());