-
Notifications
You must be signed in to change notification settings - Fork 48
Description
Describe the enhancement:
The new output option es_deadletter_index allows to send events which returned from elastic with an error code to a dedicated deadletter index/datastream. This works very well to analyse issues like mapping errors etc.
Currently it seems that failing messages are forwarded to the deadletter index regardless of the error type.
IMO it would make sense to improve this behavior and not forward messages with certain types of errors.
See the example below.
Describe a specific use case for the enhancement or feature:
Our deadletter index contains events which failed due to read timeouts.
ConnectionTimeout caused by - ReadTimeoutError(HTTPSConnectionPool(host='acme.es.eu-central-1.aws.cloud.es.io', port=443): Read timed out. (read timeout=30))
These errors are caused by cloudfront log congestion during some peak hours or when redriving events from the continuing dealetter que. IMO these events should not be sent to the deadletter queue, since they would be kind lost (unparsed) and cause even more congestion. These cases should be still handled by the continuing queue and finally the continuing dlq.