I use RestartSource.withBackoff to recover from broker outages.
https://doc.akka.io/docs/akka/current/stream/stream-error.html#delayed-restarts-with-a-backoff-stage
Hope that helps.
Michał
On Friday, 12 January 2018 22:41:04 UTC, Sean Rohead wrote:
>
> I am using akka-stream-kafka 0.18. I have
I found this article with a possible
solution:
https://blog.softwaremill.com/akka-streams-pitfalls-to-avoid-part-2-f93e60746c58
Item 6 in the article says that applying a supervision strategy using
withAttributes should be done at the END of the stream definition, unless
you are changing
