0

我正在尝试设置一个 Elasticsearch 高级休息客户端，以通过 Http Host 设置和常规凭据身份验证与已设置的 ES 集群连接。我将其设置为定期将数据从本地系统摄取到中央集群。我的代码片段如下所示：

    final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
    credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(username, password));
    RestClientBuilder builder = RestClient.builder(new HttpHost(host, port, "https"))
        .setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() {
            @Override
            public HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpClientBuilder) {
                return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
            }
        });

但是，我似乎面临错误：“必须将派生自 HttpClientConfigCallback() 的类匿名类声明为抽象或在 HttpClientConfigCallback 中实现抽象方法 customizeHttpClient(HttpAsyncClientBuilder)”，并且在其后的 @Override 方法上也出现错误，指出“方法确实不要从它的超类中覆盖方法”。

谁能告诉我应该如何实现该抽象方法还是需要导入其他任何东西？

4

0 回答 0