Как получить failMessage из полезных данных в ErrorMessage в весеннем облачном потоке kafka?

Question

Мне нужно использовать сообщение об ошибке и, в зависимости от причины сбоя, либо повторить попытку, либо отклонить сообщение.Чтобы проверить это, я явно выбрасываю исключение времени выполнения из своего кода. Я вижу, что originalMessage и заголовки в ErrorMessage имеют значение null.Но я вижу свою полезную нагрузку в виде байтового массива и свой настраиваемый заголовок в failMessage полезной нагрузки. Как я могу получить это?я не вижу получателей, указанных для свойства failedMessage в полезной нагрузке ErrorMessage.

Answer 1

failedMessage является свойством полезной нагрузки, которая является MessagingException.В ролях ...

Message<?> failed = ((MessagingException) em.getPayload()).getFailedMessage();