RestHighLevelClient不能与elasticsearch 7 BulkProc处理器一起使用。应该使用哪个客户端？
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客户端不能与elastisearch7中的bulkprocessor一起使用。
这与他们在elasticsearch 6-https://www.elastic.co/guide/en/elasticsearch/client/java-api/6.4/client.html
有人能提到他们在elasticsearch 7中使用bulkprocessor的客户机吗
共有1个答案
RestHighLevelClient可与ElasticSearch7处理器一起使用。你应该看看源代码。唯一的变化是RestHighLevelClient bulkAsycn方法。现在它需要一个额外的参数RequestOptions。所以之前签名是-
BulkProcessor.builder(restHighLevelClient()::bulkAsync, listener);
新签名如下-
BulkProcessor.builder((request, bulkListener) -> restHighLevelClient.bulkAsync(request, RequestOptions.DEFAULT, bulkListener), bulkProcessorListener
);
希望有帮助
-
问题内容： 由于我没有收到对最后一个问题的肯定回答。我将尝试自己编写一个Java FTP上传小程序。 我的问题是：“您能推荐一个Java FTP客户端库供我使用吗？” 我希望它是： 稳定 能够处理被动和主动模式 能够提供上传进度信息 如果出了问题（尤其是上传不成功时），则引发可捕获的异常 便宜/免费使用，最好是开源的 我发现这个 概述了一些库，但由于这篇文章是从2003年，也许一些新的事态发展已经
-
我尝试使用Java中的Sockets连接到多个客户端。一切似乎都正常，但问题是，服务器只监听第一个客户端。如果有多个客户端，服务器可以向它们发送所有消息，但他可以只监听来自第一个客户端的消息。我尝试了所有这些（我从昨天开始就遇到了这个问题）。所以我很确定，错误一定在“ClientListener”类中。 说明：有一个客户端列表（用于与字符串通信的连接）。在GUI中有一个列表，我可以在其中选择要与哪
-
问题内容： 当前，有大量用于node.js 的websocket库，最受欢迎的似乎是： https://github.com/Worlize/WebSocket-Node https://github.com/einaros/ws https://github.com/LearnBoost/engine.io https://github.com/learnboost/socket.io http
-
我试图用DataJpaTest注释测试我的存储库，但出现了一些奇怪的情况。 当我使用经典的时，一切正常，我的测试成功了。但是当我使用下面的生成器时，我的测试失败了。 测试应该成功，但其他测试没有成功，因为没有抛出关于约束有效性的异常。 例如，这里有一个失败的断言： Java语言AssertionError：预期测试将抛出org的实例。springframework。道。DataIntegrityV
-
我的application.properties文件中有以下属性。 当我使用注释在spring控制器中使用属性时，它给我的值为2003，但当我通过获得它的值时，我获得的值为 如何使用AbstractenVironment获得值2003？
-
问题内容： 我需要创建一些东西来从PLC读取数据并将其写入SQL数据库。我主要与西门子（和Sigmatek）合作，我认为OPC- UA是一个很好的解决方案。我的问题是，我不知道从此开始的“正确”方法是什么。使用PLC时，您有时会接触C或C ++（我总是忘记哪一个）。因此，我认为这将是一个很好的起点，但与SQL数据库的良好连接将非常方便。那对我来说事情变得模糊了。 过去，我编写了一些代码（用C＃语言