跳到主要内容
版本:5.0.1

错误通道

DeepSeek V3 中英对照 Error Channels

从版本 1.3 开始,binder 无条件地将异常发送到每个消费者目的地的错误通道,并且还可以配置为将异步生产者发送失败发送到错误通道。有关更多信息,请参阅错误处理部分。

ErrorMessage 的负载是一个 KafkaSendFailureException,其属性如下:

  • failedMessage: 发送失败的Spring Messaging Message<?>消息。

  • record: 根据failedMessage创建的原始ProducerRecord记录。

没有自动处理生产者异常(例如发送到死信主题)的机制。您可以使用自己的Spring Integration流程来消费这些异常。