I am new to Fluentd (and the hole EFK stack). I have Fluentd which sends the logs to Elasticsearch (both in Kubernetes) and I am trying to find a way to find the time when the last (successful) flush of the buffer happened.

I can think of two ways but both look like workarounds and lead to additional problems:

1. To use some proxy between the Fluentd and Elasticsearch
2. Somehow to make fluentd itself to log more logs and check for the proper log.

Is there some other more beautiful way?