Kafka Streams, установите заголовки перед ветвлением - PullRequest
0 голосов
/ 01 ноября 2019

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

IsЕсть ли способ сделать это с помощью Streams DSL или API низкого уровня является единственным выбором?

...