如何在 elasticsearch 6.2 中创建集群
How to Create culster in elasticsearch 6.2
Settings settings = Settings.builder()
.put("client.transport.ignore_cluster_name", false)
.put("client.transport.sniff", true)
.put("cluster.name", "TESTCULSTER").build();
TransportClient client = new PreBuiltTransportClient(settings)
.addTransportAddress(new TransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
// ClusterAdminClient clusterAdminClient = client.admin().cluster();
ClusterHealthResponse healths = client.admin().cluster().prepareHealth().get();
String clusterName = healths.getClusterName();
System.out.println(clusterName);
我收到这个错误
线程异常 "main" NoNodeAvailableException[None 配置的节点可用:[{#transport#-1}{zJ52yLDcR82UUQ7j-oxm6w}{127.0.0.1}{127.0.0.1:9300}]]
您想通过 Java 连接到 elasticsearch,对吗?
- 我建议使用 HTTP 传输(端口 9200)而不是 9300
- 您启用了 "sniffing",这意味着 Java 客户端将尝试直接连接到每个节点,确保可以通信
- 确保您可以
curl
您的 ES 节点 运行 Java 客户端
Settings settings = Settings.builder()
.put("client.transport.ignore_cluster_name", false)
.put("client.transport.sniff", true)
.put("cluster.name", "TESTCULSTER").build();
TransportClient client = new PreBuiltTransportClient(settings)
.addTransportAddress(new TransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
// ClusterAdminClient clusterAdminClient = client.admin().cluster();
ClusterHealthResponse healths = client.admin().cluster().prepareHealth().get();
String clusterName = healths.getClusterName();
System.out.println(clusterName);
我收到这个错误 线程异常 "main" NoNodeAvailableException[None 配置的节点可用:[{#transport#-1}{zJ52yLDcR82UUQ7j-oxm6w}{127.0.0.1}{127.0.0.1:9300}]]
您想通过 Java 连接到 elasticsearch,对吗?
- 我建议使用 HTTP 传输(端口 9200)而不是 9300
- 您启用了 "sniffing",这意味着 Java 客户端将尝试直接连接到每个节点,确保可以通信
- 确保您可以
curl
您的 ES 节点 运行 Java 客户端