I have a logstash instance reading from a kafka topic, writing to an ES5.x cluster.
When an ES insert fails due to "StrictDynamicMappingException", I would like to be alerted on the failure, optionally sending the payload to a different kafka topic for perusal.
Anyone know if/how that can be done?
Thanks.