错误通道
从 1.3 版本开始,Binder 无条件地将异常发送到每个消费者目标的错误通道,并且还可以配置为将异步生产者发送失败发送到错误通道。请参阅关于错误处理的此部分以了解更多信息。
发送失败的ErrorMessage
的有效负载是具有以下属性的KafkaSendFailureException
-
failedMessage
:发送失败的 Spring MessagingMessage<?>
。 -
record
:从failedMessage
创建的原始ProducerRecord
。
没有自动处理生产者异常(例如发送到死信主题)。您可以使用您自己的 Spring Integration 流程来消费这些异常。