錯誤通道

從版本 1.3 開始,Binder 無條件地將每個消費者目標的異常傳送到錯誤通道,也可以配置為將非同步生產者傳送失敗傳送到錯誤通道。有關更多資訊,請參閱錯誤處理部分。

傳送失敗的 ErrorMessage 的有效負載是 KafkaSendFailureException,具有以下屬性:

  • failedMessage: 傳送失敗的 Spring Messaging Message<?>

  • record: 由 failedMessage 建立的原始 ProducerRecord

沒有自動處理生產者異常(例如傳送到死信主題)。你可以使用自己的 Spring Integration 流來消費這些異常。