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