Мне сложно понять, как правильно обрабатывать исключение десериализации в потоке Spring Cloud. В первую очередь потому, что реализованная структура не поддерживает заголовки, и предполагается, что DLQ представляет собой отдельную схему, чем исходное сообщение. Таким образом, поток процесса должен выглядеть следующим образом: использовать сообщение - ›ошибка десериализации -› DlqHandler - ›сериализовать с НОВОЙ схемой -› отправить в DLQ
Документация, ссылка на которую приведена ниже, не дает хорошего представления о том, возможно ли это вообще. Я видел довольно много примеров SeekToCurrentErrorHandler для Spring-Kafka, но, насколько мне известно, это разные реализации и не соответствуют тому, как я мог бы правильно получить ошибку десериализации, а затем иметь раздел для настраиваемого кода для сериализации в новый формат и перемещения оттуда.
Мой главный вопрос: возможен ли захват исключения десериализации и повторная сериализация с помощью весенних облачных потоков (кафка)?
