錯誤通道

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

傳送失敗的 ErrorMessage 的有效負載是一個 KafkaSendFailureException,其屬性如下:

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

  • record:從 failedMessage 建立的原始 ProducerRecord

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

© . This site is unofficial and not affiliated with VMware.