On some projects we need to fetch all results from Elasticsearch.
This is currently quite difficult.
Here is an example of usage that could be implemented:
from("direct:search") .to("elasticsearch-rest://elasticsearch?operation=Search&indexName=twitter&indexType=tweet&useScroll=true&scrollKeepAliveMs=30000") .split() .body() .streaming() .to("mock:output") .end();
Two new parameters could be used:
- useScroll: enable scroll usage
- scrollKeepAliveMs: time in ms during which elasticsearch will keep search context alive
- links to