Feature request: RestartWithBackOffAndFallback for Flow & Sink
Open
t:stream
- Dominant language
- Scala
- Stars
- 1.6k
- Forks
- 211
- Avg merge
- 1d 6h
- Merged PRs (30d)
- 89
Description
Motivation:
I saw in https://github.com/akka/akka/issues/30267 @nvollmar added this feature for actor, but I think it would be nice to have this in pekko-stream, where user can logging the error with a restart/resume, and currently ,we just simply ignore it.
I found the related case from @tg44 in https://discuss.lightbend.com/t/recover-from-sink-exceptions/10554
I think this should be very useful for real production usecase.
Result:
More handy control over the exceptions
Contributor guide
Assessment
This issue has not been assessed yet.