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