elasticsearch - RestHighLevelClient 不能与 elasticsearch 7 BulkProcessor 一起使用。应该使用哪个客户端？

Question

elasticsearch 7 文档 - https://www.elastic.co/guide/en/elasticsearch/client/java-api/current/java-docs-bulk-processor.html

提到要使用的客户端如下- https://www.elastic.co/guide/en/elasticsearch/client/java-api/current/client.html

这里 HightLevelRest Client 不能和 elastisearch7 中的 bulkprocessor 一起使用。

这与他们在 elasticsearch 6 中的建议不同 - https://www.elastic.co/guide/en/elasticsearch/client/java-api/6.4/client.html

有人可以提到他们在 elasticsearch 7 中使用哪个客户端和 bulkprocessor

Answer 1

RestHighLevelClient 可以与 ElasticSearch7 BulkProcessor 一起使用。你应该看看源代码。唯一的变化是 RestHighLevelClient bulkAsycn 方法。它现在需要一个附加参数 RequestOptions。所以之前的签名是 -

BulkProcessor.builder(restHighLevelClient()::bulkAsync, listener);

新签名如下-

BulkProcessor.builder((request, bulkListener) -> restHighLevelClient.bulkAsync(request, RequestOptions.DEFAULT, bulkListener), bulkProcessorListener
            );

希望对你有帮助