He-Pin commented on issue #980:
URL:
https://github.com/apache/incubator-pekko/issues/980#issuecomment-1900072239
@mdedetrich I think what's @tg44 needs is :
1. a RestartSink, with is currently missing, maybe that can be done with the
RestartFlow.to(IgnoreSink)
2. a fallback, but for the sink, the main sink was a `fileIO` sink ,but
after some max retry, switch to a `Sink.ignore`.
```scala
Data --> Process A ----> Process FileIO Sink (main, can retry with backoff
restart)
|
| (only switch after the main sink
die and restart up to the max limit)
|
|----> fallback Ignore Sink(logging)
maybe.
````
And I think this is what he really want.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
