SpringCloud 錯(cuò)誤通道

2023-11-28 16:29 更新

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

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

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

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


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

掃描二維碼

下載編程獅App

公眾號(hào)
微信公眾號(hào)

編程獅公眾號(hào)