How to connect to remote server using Elasticsearch Node Client Java

Question

I am trying to connect to my server using Elasticsearch Java NodeBuilder Client. However I do not see any option to specify my server address and port (like we can do in Transport Client, using addNewTransportAddress("serveraddress", port)). How do I make Node Client connect to my server? Code is below, where do I mention the server address to connect to?

//On Startup
Node node = nodeBuilder()
        .clusterName("elasticsearch")
        .data(false) //No shards allocated; or can set client to true
        .client(true) //No shards allocated; or can set data to false
        .node();

//Node Client
Client client = node.client();

//Get API       
GetResponse response = client.prepareGet("indexname", "type", "id")
        .execute()
        .actionGet();

System.out.println("----------------Index Output Begin----------------");
System.out.println("Index Name: " + response.getIndex());
System.out.println("Type: " + response.getType());
System.out.println("Document ID: " + response.getId());
System.out.println("Document Version: " + response.getVersion());
System.out.println("Source: " + response.getSourceAsString());

Clinkscales

Answer 1

The node client is base on multicast. The network between your clients and the nodes have to be in the network that has multicast enable. And then the client will "discover" the nodes base on the cluster name.

If you need to connect to the remote servers (by specifying the ip addresses), you have to use the transport client.

Settings settings = ImmutableSettings.settingsBuilder()
        .put("cluster.name", "myClusterName").build();
Client client = new TransportClient(settings)
        .addTransportAddress(new InetSocketTransportAddress("host1", 9300))
        .addTransportAddress(new InetSocketTransportAddress("host2", 9300));

Libbielibbna

Answer 2

I got "ImmutableSettings cannot be resolved" when I used ImmutableSettings.

My code is:

Node node =nodeBuilder()
           .settings(ImmutableSettings.settingsBuilder().put("path.home",   "/home/amit/elasticsearch-2.1.0/bin"))
            .client(true)
            .node();
        Client client = node.client(); 

Faxen

I had same issue. It seems ImmutableSettings is replaced by Settings in 2.2.0 version – Brotherson

Node node= NodeBuilder.nodeBuilder().settings(Settings.builder() .put("path.home", "/media/rajnish/7F58-E3202/elasticsearch-2.1.0")) .client(false) .local(true) .node(); //Create Client Object. Client client = node.client(); – Faxen