Not abe to connect to elastic search cloud cluster from Transport Client

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.
;

There is a big red warning in cloud when you use 6.1.1:

You need to use for now the Java REST Client for now or wait a bit for the team to fix that problem, I believe.

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.