错误通道

DeepSeek V3 中英对照 Error Channels

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

ErrorMessage 的负载在发送失败时是一个 KafkaSendFailureException，它具有以下属性：

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

• record: 从 failedMessage 创建的原始 ProducerRecord

没有自动处理生产者异常（例如发送到死信主题）。你可以使用自己的 Spring Integration 流来消费这些异常。