Hi,
I am trying to configure ELK cluster with kafka. I am using filebeat to ship the logs to kafka and logstash to grep the logs from kafka, process the logs and send it to elasticsearch. I need to find out a way to persist time from filebeat to elasticsearch and check the lagging between kafka and logstash. How can I find out the lagging and preserve the time?
Cheers
Ferdous Shibly