Hello ES/Logstash Gurus,
As I am new with Elastic Stack, I need your help.
I am working on one of the Use Case which requires to transfer the data from one Elastic Search Cluster to another Elastic Search cluster in real-time.
I am thinking of implementing LogStash using a query on the source elastic search cluster, this should use query to fetch all records newer than the last time it ran and send it to the destination ES cluster.
I will really appreciate some reference for the solution or how can I fetch the new record from the source for every run.