SpringCloud 錯誤通道

2023-11-28 16:29 更新

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

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

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

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


以上內容是否對您有幫助:
在線筆記
App下載
App下載

掃描二維碼

下載編程獅App

公眾號
微信公眾號

編程獅公眾號