Elasticsearch 批量操作发生故障时如何获取文档字段？

Question

我目前正在使用批量请求将实体从 DBMS 迁移到 Elasticsearch，但我希望能够确定哪些特定实体在操作期间失败（无需在操作后查询 Elastic）。 我注意到BulkItemResponse.Failure 类有一个ID_FIELD，但这似乎是动作，而不是文档。

响应中是否有任何字段可用于检索失败文档的字段？

Answer 1

在阅读了 Elasticsearch 论坛之后，似乎只能在批量请求中检索文档的索引，而不能检索文档的内容 https://discuss.elastic.co/t/way-to-re-index-failed-documents-using-bulkprocessor/33736/3

作为记录，这是我从批量响应中提取失败项目 ID 的方式：

List<Integer> processBulkResponse(BulkResponse bulkResponse) {
    List<Integer> failures = new ArrayList<>();
    for (BulkItemResponse bulkItemResponse : bulkResponse) {
        if (bulkItemResponse.isFailed()) {
            failures.add(bulkItemResponse.getItemId());
        }
    }
    return failures;
}