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