java - 如何在 Elasticsearch Java 高级客户端 6.8 的响应中只获取失败的文档

Question

在使用 Elasticsearch Java 高级 REST 客户端进行批量请求时，是否有任何方法可以仅在响应中获取失败的文档。

目前，ES 正在响应中发送所有成功和失败的文档，我们正在重新处理所有失败的文档，我们正在迭代 BulkItemResponse 以找到失败的文档并重新处理它。

private BulkRequest createBulkRequestsForRetry(BulkResponse bulkItemResponses, BulkRequest currentBulkRequest) {
        BulkRequest bulkRequest = new BulkRequest();
        int index = 0;
        for (BulkItemResponse bulkItemResponse : bulkItemResponses.getItems()) {
            if (bulkItemResponse.isFailed()) {
                bulkRequest.add(currentBulkRequest.requests().get(index));
            }
            index++;
        }
        return bulkRequest;
    }

作为 bulkItemResponse.getItems() 表示批量操作中执行的每个操作(以相同的顺序!)。

Answer 1

到目前为止，即使在最新的 7.7 版本的客户端中，这个功能也不存在，如果你想要这个功能，你可以创建一个问题或者更好地提交一个 PR 来解决这个问题，这将是一个非常有用的功能.

你可以看看complete BulkResponse看看你自己，master 分支中也没有这样的功能。

还有 here您可以向 Elasticsearch 创建问题。