Problem: Every 20 minutes logstash fetches all the records matching as per query in batches of 100(size=100) and waits for next schedule.
in input plugin i have something like this:
size => 100
schedule => "*\20 * * * *"
NEED: I wanted to retrieve only 100 records from matching set of records against the query every 20 minutes from elasticsearch using logstash.
I will really appreciate the some help here.