Я запускаю приложение Akka Streams Kafka, и я хочу включить стратегию наблюдения в потребителя потока, чтобы, если брокер выходит из строя, а потребитель потока умирает после тайм-аута остановки, супервизор может перезапустить потребителя. Вот мой...