Stop reading from Kafka's topic by logstash in case of error (400,404)

Elastic Stack Logstash
1

Hello everyone,

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.

2

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.