錯誤通道
從 1.3 版本開始,繫結器無條件地將異常傳送到每個消費者目標的錯誤通道,並且還可以配置為將非同步生產者傳送失敗傳送到錯誤通道。有關更多資訊,請參閱關於錯誤處理的這一部分。
傳送失敗的 ErrorMessage 的有效負載是一個 KafkaSendFailureException,其屬性如下:
-
failedMessage:未能傳送的 Spring MessagingMessage<?>。 -
record:從failedMessage建立的原始ProducerRecord。
生產者異常(例如傳送到死信主題)沒有自動處理。您可以使用自己的 Spring Integration 流來消費這些異常。