Has anyone any experience with the new StreamRefs? I’m looking to use them in a cluster where a job offers a SourceRef to sharded workers and just wondering what happens if a worker node gets re-balanced, will the stream recover? Is there a backoff & retry?
The documentation: https://doc.akka.io/docs/akka/2.5/stream/stream-refs.html mentions the following:
Stream refs are absolutely expected to be sent over Akka remoting to other nodes within a cluster, and as such, complement and do not compete with plain Actor messaging. Actors would usually be used to establish the stream, by means of some initial message saying “I want to offer you many log elements (the stream ref)”, or alternatively in the opposite way “If you need to send me much data, here is the stream ref you can use to do so”.
What happens during failure after the initial offer of a stream ref…?