I have a question about error processing in Logstash. In my case, i have the following cluster:
Kafka -> Logstash -> Elasticsearch
As far as I understood, if Logstash reads messages from Kafka's topic and unable to write them into Elasticsearch with error code 400 or 404, then Logstash will continue to read messages from the input (Kafka). Is there any way to stop reading messages from Kafka after receiving such kind of error?
Thanks in advance.