https://www.elastic.co/guide/en/shield/current/_using_elasticsearch_java_clients_with_shield.htmlTransportClient client = TransportClient.builder()
.addPlugin(ShieldPlugin.class)
.settings(Settings.builder()
.put("cluster.name", "myClusterName")
.put("shield.user", "transport_client_user:changeme")
...
Regarding configuring an elastic search sink, is there any way adding the shield plugin as per elastic search java client api documentation.
It seems like the TransportClient object is a private member in the ElastSearchSink class, so there's no way to access the builder.
If there is now way, is there any other option for authorizing request against es indexes with shield installed?
Locked
