我正在尝试设置一个elasticsearch高级rest客户机,通过http主机设置和常规凭证身份验证与已经设置好的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()派生的类匿名类必须声明为abstract,或者在httpclientconfigcallback中实现抽象方法customizehttpclient(httpasyncclientbuilder)”,以及它后面的@override方法上的一个错误,声明“方法不重写其超类中的方法”。
有人能告诉我应该如何实现这个抽象方法吗?或者我需要导入其他东西吗?
暂无答案!
目前还没有任何答案,快来回答吧!