Hello!

We are internally having a debate on how best to handle exceptions within our 
operators. Some advocate for wrapping maps/flatMaps inside a processfunction 
and sending the error to a side output. Other options are returning a custom 
Either that gets filtered and mapped into different sinks.  

Are there any recommendations or standard solutions to this?

-Steve

Reply via email to