Комментарии 1
Очень хотелось бы увидеть что-то про обработку ошибок. Как организовать ретраи или circuit-breaker? Что будет если один из процессоров в стриме упадет с ошибкой.
Просто я помню как мучался с подобным в akka-streams и это было прям болью.
К примеру можно-ли хотя-бы в отдельный топик направить все сообщения которые вызвали сбои топологии?
Зарегистрируйтесь на Хабре, чтобы оставить комментарий
Потоковая обработка данных с помощью Kafka Streams: архитектура и ключевые концепции