java - 从 BulkRequest 捕获特定的 Elasticsearch 异常

Question

我使用 Java 将一些带有 BulkRequest 的文档索引到 Elasticsearch 1.4.2 中。

其中一些文档仅在索引中尚未存在时才需要写入，因此我将 CREATE-opType 设置为如下:

indexRequestBuilder.opType(IndexRequest.OpType.CREATE)

现在索引中已有的文档在 BulkResponse 中失败。

错误消息bulkItemResponse.getFailureMessage():

DocumentAlreadyExistsException[...]

我想忽略此类异常，但重新尝试为所有其他类型的异常编写文档。

那么我怎样才能捕获DocumentAlreadyExistsException？

我可以使用 bulkItemResponse.getFailure() 获取 Failure，但除了错误消息之外，我找不到有关异常类型的任何信息。

我可以在错误消息中查找异常名称，但这对于新的 Elasticsearch 版本可能相当脆弱:

if(bulkItemResponse.getFailureMessage().startsWith("DocumentAlreadyExistsException[")

有更好的方法吗？

Answer 1

这不可能。批量请求实际上是在服务器端而不是客户端执行的。因此它所能做的就是发回堆栈跟踪而不是异常对象。