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