错误通道

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

发送失败的 ErrorMessage 的有效负载是 KafkaSendFailureException,它具有以下属性:

  • failedMessage: 未能发送的 Spring Messaging Message<?>

  • record: 从 failedMessage 创建的原始 ProducerRecord

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