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
I am using akka-stream-kafka 0.18. I have a flow that reads from one kafka
topic, does some processing and then writes to a different kafka topic. The
flow has been shutting down intermittently when kafka brokers fail.
Sometimes the brokers will fail repeatedly over a long period and the flow
