SpringCloud 處理反序列化異常

2023-11-29 15:32 更新

Kafka Streams活頁夾通過以下屬性支持選擇異常處理程序。

spring.cloud.stream.kafka.streams.binder.serdeError: logAndContinue

除了上述兩個反序列化異常處理程序之外，綁定程序還提供了第三個用于將錯誤記錄（毒丸）發(fā)送到DLQ主題的代理。這是啟用此DLQ異常處理程序的方法。

spring.cloud.stream.kafka.streams.binder.serdeError: sendToDlq

設(shè)置以上屬性后，所有反序列化錯誤記錄都會自動發(fā)送到DLQ主題。

spring.cloud.stream.kafka.streams.bindings.input.consumer.dlqName: foo-dlq

如果已設(shè)置，則錯誤記錄將發(fā)送到主題foo-dlq。如果未設(shè)置，則它將創(chuàng)建名稱為error.<input-topic-name>.<group-name>的DLQ主題。

在Kafka Streams活頁夾中使用異常處理功能時，需要記住兩件事。

  • 屬性spring.cloud.stream.kafka.streams.binder.serdeError適用于整個應(yīng)用程序。這意味著如果同一應(yīng)用程序中有多個StreamListener方法，則此屬性將應(yīng)用于所有這些方法。
  • 反序列化的異常處理與本機反序列化和框架提供的消息轉(zhuǎn)換一致。
以上內(nèi)容是否對您有幫助：
在線筆記
App下載
App下載

掃描二維碼

下載編程獅App

公眾號
微信公眾號

編程獅公眾號