Restore rabbit message when elastic reject them

Hello every one,

i have the next scenario:

In my logstash pipeline, in input I have configured the rabbitmq , so we take messages from Rabbitmq and then we send them to elasticsearch.
But sometimes the message is rejected by elastic and we lose those messages (400 response)

I need don't lose those messages (maybe resend those messages to rabbitmq again) .Any ideas?


A DLQ might help, but that really depends on why the messages are rejected.

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