Querying/Searching a cluster/Multiple elasticsearch nodes

[anisen (Anirban Sen)]

Hi,
I am using ES 5.1.1. I had only one elasticsearch node. And I was able to search/view data like below:

1) http://192.168.10.10:9200/myIndex/_search

2) Settings settings = Settings.builder().put("cluster.name", "my-application").build();
TransportClient client = new PreBuiltTransportClient(settings)
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getLocalHost(),9300));
String json = "{"query":{"match_all":{}}}";
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
SearchModule searchModule = new SearchModule(Settings.EMPTY, false, Collections.emptyList());
try (XContentParser parser = XContentFactory.xContent(jsonDistinctUrls).createParser(json)) {
QueryParseContext context = new QueryParseContext(searchModule.getQueryParserRegistry(), parser,
new ParseFieldMatcher(true));
searchSourceBuilder.parseXContent(context, searchModule.getAggregatorParsers(),
searchModule.getSuggesters(), searchModule.getSearchExtRegistry());
}

SearchRequestBuilder searchRequestBuilder = newSearchRequestBuilder(client, SearchAction.INSTANCE);
SearchResponse srDistinctUrls = searchRequestBuilder.setIndices(indexName).setSource(searchSourceBilder).execute().actionGet();

But, now I am using two nodes for elasticsearch.

My Logstash config file output looks like below:
output {
elasticsearch {
action => "index"
hosts => ["192.168.10.10:9200","192.168.20.20:9200"]
index => "myIndex"
}
}

What code changes I need to do now?

[dadoonet (David Pilato)]

You can call again addTransportAddress and add the new address.

That said it's not mandatory. Elasticsearch will load balance the requests within the cluster even if you declare only one node in the transport client.

The nodes you use from the transport client are named coordinating nodes.

[anisen (Anirban Sen)]

Hi David, Thanks for the response.

So, I changed the code to this now adding two addresses.
TransportClient client = new PreBuiltTransportClient(settings)
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("hostname1"),9300))
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("hostname2"),9300));

But I'm getting resulting from the 1st node only, i.e. hostname1.

What changes do I need to do in the elasticsearch.yml files in both the nodes? Plz suggest.