一、报错内容

Exception in thread "main" ElasticsearchStatusException[Elasticsearch exception [type=security_exception, reason=missing authentication credentials for REST request [/user2?master_timeout=30s&ignore_unavailable=false&expand_wildcards=open%2Cclosed&allow_no_indices=true&ignore_throttled=false&timeout=30s]]]

    at org.elasticsearch.rest.BytesRestResponse.errorFromXContent(BytesRestResponse.java:176)

    at org.elasticsearch.client.RestHighLevelClient.parseEntity(RestHighLevelClient.java:2011)

    at org.elasticsearch.client.RestHighLevelClient.parseResponseException(RestHighLevelClient.java:1988)

    at org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1745)

    at org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1702)

    at org.elasticsearch.client.RestHighLevelClient.performRequestAndParseEntity(RestHighLevelClient.java:1672)

    at org.elasticsearch.client.IndicesClient.delete(IndicesClient.java:103)

    at com.xxx.elasticsearch.operation.main(operation.java:26)

        Suppressed: org.elasticsearch.client.ResponseException: method [DELETE], host [http://10.219.87.159:32705], URI [/user2?master_timeout=30s&ignore_unavailable=false&expand_wildcards=open%2Cclosed&allow_no_indices=true&ignore_throttled=false&timeout=30s], status line [HTTP/1.1 401 Unauthorized]

{"error":{"root_cause":[{"type":"security_exception","reason":"missing authentication credentials for REST request [/user2?master_timeout=30s&ignore_unavailable=false&expand_wildcards=open%2Cclosed&allow_no_indices=true&ignore_throttled=false&timeout=30s]","header":{"WWW-Authenticate":"Basic realm=\"security\" charset=\"UTF-8\""}}],"type":"security_exception","reason":"missing authentication credentials for REST request [/user2?master_timeout=30s&ignore_unavailable=false&expand_wildcards=open%2Cclosed&allow_no_indices=true&ignore_throttled=false&timeout=30s]","header":{"WWW-Authenticate":"Basic realm=\"security\" charset=\"UTF-8\""}},"status":401}

    at org.elasticsearch.client.RestClient.convertResponse(RestClient.java:326)

    at org.elasticsearch.client.RestClient.performRequest(RestClient.java:296)

    at org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)

    at org.elasticsearch.client.RestHighLevelClient.performClientRequest(RestHighLevelClient.java:2082)

    at org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1732)

    ... 4 more

二、报错内容

三、报错解决

ElasticsearchSink.Builder<String> esSinkBuilder = new ElasticsearchSink.Builder<>(httpHosts,

    new ElasticsearchSinkFunction<String>() {

        public IndexRequest createIndexRequest(String element) {

            Map<String, String> json = new HashMap<>();

            json.put("data", element);

            return Requests.indexRequest()

                .index("您的索引名")

                //.type("my-type")

                .source(json);

        }

        @Override

        public void process(String element, RuntimeContext ctx, RequestIndexer indexer) {

            indexer.add(createIndexRequest(element));

        }

    }

);

// 鉴权，正对写 es 需要密码的场景

esSinkBuilder.setRestClientFactory(new HDRestClientFactory("您的账号名", "您的密码"));

public class HDRestClientFactory implements RestClientFactory {

    private String userName;

    private String password;

    transient CredentialsProvider credentialsProvider;

    public HDRestClientFactory(String userName, String password) {

        this.userName = userName;

        this.password = password;

    }

    @Override

    public void configureRestClientBuilder(RestClientBuilder restClientBuilder) {

        if (credentialsProvider == null) {

            credentialsProvider = new BasicCredentialsProvider();

            credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(userName, password));

        }

        restClientBuilder.setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() {

            @Override

            public HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpAsyncClientBuilder) {

                return httpAsyncClientBuilder.setDefaultCredentialsProvider(credentialsProvider);

            }

        }).setRequestConfigCallback(new RestClientBuilder.RequestConfigCallback() {

            @Override

            public RequestConfig.Builder customizeRequestConfig(RequestConfig.Builder builder) {

                builder.setConnectTimeout(5000);

                builder.setSocketTimeout(60000);

                builder.setConnectionRequestTimeout(2000);

                return builder;

            }

        });

    }

}

免责申明：

本文系转载，版权归原作者所有，如若侵权请联系我们进行删除！

《数据治理行业实践白皮书》下载地址：https://fs80.cn/4w2atu

《数栈V6.0产品白皮书》下载地址：https://fs80.cn/cw0iw1

想了解或咨询更多有关袋鼠云大数据产品、行业解决方案、客户案例的朋友，浏览袋鼠云官网：https://www.dtstack.com/?src=bbs

同时，欢迎对大数据开源项目有兴趣的同学加入「袋鼠云开源框架钉钉技术群」，交流最新开源技术信息，群号码：30537511，项目地址：https://github.com/DTStack