|
此版本仍在开发中，尚未被视为稳定版本。对于最新的稳定版本，请使用 spring-cloud-stream 4.1.4！ |
错误通道
从版本 1.3 开始，Binder 无条件地将异常发送到每个 Consumer 目标的错误通道，并且还可以配置为将异步 producer send failures发送到 error 通道。 有关更多信息，请参阅此错误处理部分。
的ErrorMessage因为发送失败是一个KafkaSendFailureException具有属性：
-
failedMessage： Spring 消息传递Message<?>未能发送。 -
record： 原始ProducerRecord它是从failedMessage
没有自动处理生产者异常（例如发送到死信主题）。 您可以在自己的 Spring 集成流中使用这些异常。