錯誤通道
從 1.3 版本開始,binder 無條件地將例外狀況發送到每個消費者目的地的錯誤通道,並且還可以配置為將異步生產者發送失敗發送到錯誤通道。有關更多資訊,請參閱關於錯誤處理的章節。
發送失敗的 ErrorMessage
的 payload 是一個具有以下屬性的 KafkaSendFailureException
-
failedMessage
:未能發送的 Spring MessagingMessage<?>
。 -
record
:從failedMessage
建立的原始ProducerRecord
沒有自動處理生產者例外狀況(例如發送到死信主題)。您可以使用自己的 Spring Integration 流程來消費這些例外狀況。