in my Logstash installation, I am passing data from a certain API over MQTT. However, in some cases, the MQTT connection is interrupted and in this case, the pipeline does not work until you restart the Logstash container. As I see from the logs, I realize that the pipeline has terminated. When I restart the container, the pipeline starts working again. What steps can I take to control this situation? I tried adding a healthcheck mechanism to automatically restart the pipeline or ensure MQTT connection, but I was unsuccessful.