How I can catch all events that failed to be written in sink (Elasticearch)?

[gl1ridae]

Hi all! I have pretty big flow of events which written into different Elasticsearch (ES) indices based on some fields. And it happens that events cannot be written because of schema errors or mapping exceptions from ES side. The question is what is the conventional way to catch these events, which failed to be written into ES, and write it into file sink for example?

[jszwedko]

Hey! Unfortunately you can't yet. This feature is being tracked by #1772

[gl1ridae]

Got it, thanks!