SpringCloud 錯誤通道

2023-11-28 16:29 更新

從版本1.3開始，綁定程序無條件地將異常發(fā)送到每個使用者目標(biāo)的錯誤通道，并且還可以配置為將異步生產(chǎn)者發(fā)送失敗消息發(fā)送到錯誤通道。有關(guān)更多信息，請參見“錯誤處理”。

發(fā)送失敗的ErrorMessage的有效載荷是具有以下屬性的KafkaSendFailureException：

  • failedMessage：發(fā)送失敗的Spring消息Message<?>。
  • record：從failedMessage創(chuàng)建的原始ProducerRecord

沒有對生產(chǎn)者異常的自動處理（例如發(fā)送到Dead-Letter隊(duì)列）。您可以使用自己的Spring Integration流使用這些異常。


以上內(nèi)容是否對您有幫助：
在線筆記
App下載
App下載

掃描二維碼

下載編程獅App

公眾號
微信公眾號

編程獅公眾號