Error Channels
从 1.3 版本开始，binder 会无条件地将异常发送到每个消费者目的地的错误通道，并且还可以配置将异步生产者发送失败发送到错误通道。 见 此部分关于错误处理 以获取更多信息。
请求的 ErrorMessage 负载为带有属性的 KafkaSendFailureException：
-
failedMessage: Spring 消息Message<?>: 发送失败的消息。 -
record: The rawProducerRecordthat was created from thefailedMessage
没有对生产者异常进行自动处理（例如发送到一个 死信主题）。 您可以使用自己的 Spring Integration 流来消费这些异常。