我需要使用错误消息，并根据失败原因重试或丢弃该消息。为了测试这一点，我从代码中明确抛出了运行时异常。我看到ErrorMessage中的originalMessage和 header 为空。但是我将有效负载视为字节数组，并将有效负载的failMessage定义为自定义 header 。我在ErrorMessage的有效负载中没有看到为failedMessage属性指定的 setter/getter 。
最佳答案
failedMessage是有效负载的属性，它是MessagingException。 Actor 吧...
Message<?> failed = ((MessagingException) em.getPayload()).getFailedMessage();
关于java - 如何从 Spring Cloud 流kafka中的错误消息中的有效负载中获取失败消息？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/54511187/