I am using 6.1.1 elastic search but while connecting to elastic cloud with transport client i am getting
java.io.StreamCorruptedException: invalid internal transport message format, got (48,54,54,50)
I am using X-pack Transport client
Settings settings = Settings.builder()
.put("client.transport.nodes_sampler_interval", "5s")
.put("client.transport.sniff", false)
.put("transport.tcp.compress", true)
.put("cluster.name", "abcd")
.put("xpack.security.transport.ssl.enabled", enableSsl)
.put("request.headers.X-Found-Cluster", "abcd")
.put("xpack.security.user", "user:password") // your shield username and password
.build();
TransportClient client = new PreBuiltXPackTransportClient(settings)
.addTransportAddress(new TransportAddress(InetAddress.getByName("xxxxxxxxxxe7be789c.us-east-1.aws.found.io"), 9243))
Please let me know if i am using missing something.
;