I have 2 questions with regard to error handling in flows:
In streams error handling it says I can use the supervision method Resume on a piece of a stream, but that the element that failed will be dropped. Is there a way to not drop the element? Say for example I have a flow or sink that uploads some data, and the upload failed, I’d like to retry uploading that data instead of letting the stream continue on without uploading it. Do i just need to implement a custom flow/sink that keeps the last received item in case of a resume or something?
In a flow composed of multiple little flows, would an error exception from one of the sub flows propagate to the composed flow object? So for example, could I set error handling for the composed flow to resume should a specific error happen in one of its subflows, retrying an element for that pipeline?