Надеюсь, у вас все отлично!
Я пишу свой собственный фильтр logsta sh плагин в Java. Я задал этот вопрос непосредственно на форуме поддержки logsta sh , к сожалению, без ответов.
Мне было интересно, так как я не мог найти много документации, Как я могу изящно обрабатывать ошибки, которые могут возникнуть при фильтрации данных?
Я звоню во внешние службы, которые могут или не могут быть недоступны, и я хотел бы поместить событие в DLQ или, по крайней мере, иметь возможность отслеживать и отслеживать ошибки.
Интерфейс co.elastic.logstash.api.Filter, который мы реализуем, не имеет throws Exception подписи, и мне еще далеко до go, прежде чем я стану экспертом.
В официальной документации пропускается вся обработка исключений.
Я буду очень рад узнать, как поместить событие в ошибку в DLQ, чтобы я мог использовать его позже, как только исправлю причину исключения (API отключен, я выскочил NPE и т. д. c ...).
Я также нашел похожий вопрос здесь о stackoverflow из 4 лет go также без реального "изящного" ответа.
Надеюсь, вы сможете ответить на мой вопрос.
Большое спасибо за вашу помощь,
Макс
Ссылки: