java - 如何从Spring云流kafka中的ErrorMessage中的有效负载获取failedMessage？

Question

我需要使用错误消息，并根据失败的原因重试或丢弃消息。为了测试这一点，我从代码中显式抛出运行时异常。我看到 OriginalMessage 和 ErrorMessage 中的 header 为空。但我将我的有效负载视为字节数组，并在有效负载的 failedMessage 中看到我的自定义 header 。我如何检索它？我在 ErrorMessage 的有效负载中看到没有为 failedMessage 属性指定 getter。

Answer 1

failedMessage 是有效负载的一个属性，它是 MessagingException。转换它...

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