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

在elastisearch7中，HightLevelRest客户端不能与批量处理器一起使用。

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

有人能提一下他们在elasticsearch 7中使用的是哪个客户端和批量处理器吗？

Answer 1

RestHighLevelClient可以与ElasticSearch7 BulkProcessor一起使用。你应该看一下源代码。唯一的变化是在RestHighLevelClient bulkAsycn方法中。它现在接受一个额外的参数RequestOptions。所以之前的签名是-

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

新的签名如下-

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

希望能有所帮助