錯誤通道

從 1.3 版本開始,binder 無條件地將例外狀況發送到每個消費者目的地的錯誤通道,並且還可以配置為將異步生產者發送失敗發送到錯誤通道。有關更多資訊,請參閱關於錯誤處理的章節

發送失敗的 ErrorMessage 的 payload 是一個具有以下屬性的 KafkaSendFailureException

  • failedMessage:未能發送的 Spring Messaging Message<?>

  • record:從 failedMessage 建立的原始 ProducerRecord

沒有自動處理生產者例外狀況(例如發送到死信主題)。您可以使用自己的 Spring Integration 流程來消費這些例外狀況。