|
对于最新的稳定版本，请使用 spring-cloud-stream 4.3.0！ |
错误通道
从 1.3 版开始，绑定器无条件地将异常发送到每个使用者目标的错误通道，也可以配置为将异步生产者发送失败发送到错误通道。 有关详细信息，请参阅此部分有关错误处理。
的有效负载ErrorMessage对于发送失败，是KafkaSendFailureException具有属性：
-
failedMessage：春季消息Message<?>未能发送。 -
record：原始的ProducerRecord这是从failedMessage
没有自动处理生产者异常（例如发送到死信主题）。 您可以在自己的 Spring Integration 流中使用这些异常。