У меня есть вопрос об обработке ошибок в Logstash.В моем случае у меня есть следующий кластер:
Kafka -> Logstash -> Elasticsearch
Из того, что я понял, если Logstash читает сообщение из темы Кафки и не может записать его в Elasticsearch,затем он перестает читать с входа (Кафка).Означает ли это, что первое сообщение, которое не было записано в ES, будет потеряно, потому что смещение Кафки будет перемещено?
Заранее спасибо.