Error Channels
从版本 1.3 开始,绑定程序会无条件地将异常发送到每个使用者目标的错误通道,并且还可以配置为将异步生产者发送失败发送到错误通道。有关更多信息,请参阅 this section on error handling。
发送失败的 ErrorMessage
的有效负载是一个 KafkaSendFailureException
,具有以下属性:
-
failedMessage
:无法发送的 Spring 消息Message<?>
。 -
record
: 从`failedMessage`创建的原始`ProducerRecord`
自动处理生产者异常(例如发送到 dead letter topic)不适用。你可以使用你自己的 Spring Integration 流程来使用这些异常。