My current flow looks like a MergeHub->grouping logic->db write->file write->Sink.ignore. Today our file write dropped an (IO)exception, and we lost a lot of data, bcs we stopped writing to the db too.
I have multiple .withAttributes(ActorAttributes.supervisionStrategy(decider))-s in the code (which is a log and a Supervision.Resume).
Is there a method/function, where if the downstream dies with an exception (multiple times), I can switch it to an another one? Like recoverWithRetries but as a Sink wrapper?