Я пытался запросить ES с URI:
.to("elasticsearch-rest://myClusterName?hostAddresses={{elasticSearchHost}}:{{elasticSearchPort}}&operation=SEARCH")
но я получаю тайм-аут:
java.io.IOException: listener timeout after waiting for [30000] ms
at org.elasticsearch.client.RestClient$SyncResponseListener.get(RestClient.java:663)
...
Мне интересно, может ли быть проблема в том, как я построил запрос
Я просто хочу простой запрос. Например, если я введу это на консоли Kibana:
GET /bike_data/_search?q=_id:0
Я встроил это в свой процессор:
SearchRequest searchRequest = new SearchRequest();
searchRequest.indices("bike_data");
MatchQueryBuilder matchQueryBuilder = new MatchQueryBuilder("id", 0);
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
searchSourceBuilder.query(matchQueryBuilder);
searchSourceBuilder.size(1);
searchRequest.source(searchSourceBuilder);
exchange.getIn().setBody(searchRequest);
Куда я иду не так?