W3Cschool
恭喜您成為首批注冊用戶
獲得88經驗值獎勵
從版本1.3開始,綁定程序無條件地將異常發(fā)送到每個使用者目標的錯誤通道,并且還可以配置為將異步生產者發(fā)送失敗消息發(fā)送到錯誤通道。有關更多信息,請參見“錯誤處理”。
發(fā)送失敗的ErrorMessage
的有效載荷是具有以下屬性的KafkaSendFailureException
:
failedMessage
:發(fā)送失敗的Spring消息Message<?>
。record
:從failedMessage
創(chuàng)建的原始ProducerRecord
沒有對生產者異常的自動處理(例如發(fā)送到Dead-Letter隊列)。您可以使用自己的Spring Integration流使用這些異常。
Copyright©2021 w3cschool編程獅|閩ICP備15016281號-3|閩公網安備35020302033924號
違法和不良信息舉報電話:173-0602-2364|舉報郵箱:jubao@eeedong.com
掃描二維碼
下載編程獅App
編程獅公眾號
聯系方式:
更多建議: