Потоковая обработка данных с помощью Kafka Streams: архитектура и ключевые концепции

[FruTb]

Очень хотелось бы увидеть что-то про обработку ошибок. Как организовать ретраи или circuit-breaker? Что будет если один из процессоров в стриме упадет с ошибкой.

Просто я помню как мучался с подобным в akka-streams и это было прям болью.

К примеру можно-ли хотя-бы в отдельный топик направить все сообщения которые вызвали сбои топологии?