Rechecking as I didn't any response. It would be helpful if someone can guide me on how to find logstash pipeline failure. For now, I'm planning to use the target Es Indice to monitor last arrived data to alert on failure, but it will work only if the data to indice is coming from only one instance.