У нас есть потоковое приложение, которое обрабатывает сообщения с использованием данных из другой темы. Если что-то пойдет не так (реестр схем недоступен, десериализация завершилась неудачно, содержимое сообщения не прошло проверку и т. Д.), Сообщение перенаправляется в тему тупика с заголовком, описывающим причину сбоя.
IsЕсть ли способ сделать это с помощью Streams DSL или API низкого уровня является единственным выбором?