Class App

elasticsearch-with-ssl/src/main/java/nl/altindag/ssl/es/App.java:38–64

import java.util.List;

public class App {

    public static void main(String[] args) throws IOException {
        Path certificatePath = Paths.get("elasticsearch-with-ssl/elasticsearch-docker/ca.crt").normalize().toAbsolutePath();
        List<Certificate> certificates = CertificateUtils.loadCertificate(certificatePath);
        SSLFactory sslFactory = SSLFactory.builder()
                .withTrustMaterial(certificates)
                .build();

        CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
        credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("elastic", "PleaseChangeMe"));

        RestClient restClient = RestClient.builder(new HttpHost("localhost", 9200, "https"))
                .setHttpClientConfigCallback(httpClientBuilder ->
                        httpClientBuilder.setSSLContext(sslFactory.getSslContext()).setDefaultCredentialsProvider(credentialsProvider))
                .build();

        ElasticsearchTransport transport = new RestClientTransport(restClient, new JacksonJsonpMapper());
        ElasticsearchClient client = new ElasticsearchClient(transport);

        HealthResponse healthResponse = client.cluster().health();
        System.out.printf("Elasticsearch status is: [%s]", healthResponse.status());

        restClient.close();
    }

}