日韩成人免费在线_国产成人一二_精品国产免费人成电影在线观..._日本一区二区三区久久久久久久久不

當前位置:首頁 > 科技  > 軟件

Spring實現Kafka重試Topic,真的太香了

來源: 責編: 時間:2024-01-08 09:17:11 200觀看
導讀概述Kafka的強大功能之一是每個分區都有一個Consumer的偏移值。該偏移值是消費者將讀取的下一條消息的值。可以自動或手動增加該值。如果我們由于錯誤而無法處理消息并想重試,我們可以選擇手動管理,并在成功的情況下增

概述

Kafka的強大功能之一是每個分區都有一個Consumer的偏移值。該偏移值是消費者將讀取的下一條消息的值。可以自動或手動增加該值。如果我們由于錯誤而無法處理消息并想重試,我們可以選擇手動管理,并在成功的情況下增加偏移量。但是,這會暫時阻止隊列消息的處理。我們可以選擇異步方法。PkI28資訊網——每日最新資訊28at.com

為什么我們需要它?

如果發生錯誤,而不是停止隊列消息的處理;我們可以將錯誤消息轉移到不同的主題并再次處理。PkI28資訊網——每日最新資訊28at.com

如果在處理 Kafka 消息時出現錯誤,可以使用 RetryableTopic 注解以一定的時間間隔和一定的次數再次處理消息。如果完成嘗試次數后錯誤仍然存在,則消息將發送到 DLT 隊列。PkI28資訊網——每日最新資訊28at.com

如何使用?

我們首先回顧一下RetryableTopic注解可以取的一些值,以便您可以做出最適合您的設置:PkI28資訊網——每日最新資訊28at.com

attempts:嘗試處理消息的次數。它的默認值為 3。如果完成所有嘗試后仍然收到錯誤,則消息將發送到 DLT 隊列。PkI28資訊網——每日最新資訊28at.com

backoff:用于確定處理消息的時間間隔。從 Backoff 類獲取一個值。您可以在下面找到退避的詳細示例。PkI28資訊網——每日最新資訊28at.com

排除/排除名稱:允許您排除指定的異常類。當您添加到列表中的任何錯誤被拋出時,重試機制將不會被激活。PkI28資訊網——每日最新資訊28at.com

include / includeNames:僅當拋出指定的異常時才會激活重試機制。PkI28資訊網——每日最新資訊28at.com

kafkaTemplate:雖然您可以給出現有 kafkaTemplate bean 的名稱,但您也可以為特定于重試的 Kafka 模板定義不同的 bean。PkI28資訊網——每日最新資訊28at.com

autoCreateTopics:決定是否自動創建Retry和DLT主題。PkI28資訊網——每日最新資訊28at.com

retryTopicSuffix / dltTopicSuffix:用于確定要添加到自動創建的主題末尾的后綴。PkI28資訊網——每日最新資訊28at.com

dltStrategy:如果不需要DLT,可以定義為NO_DLT。PkI28資訊網——每日最新資訊28at.com

SameIntervalTopicReuseStrategy/fixedDelayTopicStrategy(3.0.4之前):用于確定要創建的重試主題策略。創建 (SINGLE_TOPIC) 或盡可能多的嘗試值 (MULTIPLE_TOPICS) 重試主題。PkI28資訊網——每日最新資訊28at.com

Backoff的示例:

  • 具有固定的增量值
Backoff(delay = 600000 ) // 每 10 分鐘
  • 具有指數價值
Backoff(delay = 60000 , multiplier = 2 ) // 1、2、4、8... 分鐘后重復。
  • 用占位符定義值
Backoff(delayExpression = "${delay}", multiplierExpression = "${multiplier}")

@RetryableTopic 示例:

@RetryableTopic(     backoff = @Backoff(delay = 300000),     attempts = 12,     sameIntervalTopicReuseStrategy =          SameIntervalTopicReuseStrategy.SINGLE_TOPIC,     kafkaTemplate = "kafkaRetryableTopicTemplate",     exclude = { SerializationException.class,                  DeserializationException.class,                  NullPointerException.class                } ) @KafkaListener(topics = "my-topic") public void processMessage(RetryableDto retryableDto) {     log.info("Retrying process RetryableDto : {}", retryableDto);     // process message }

在上面的例子中,消息將每5分鐘重新處理一次,總共12次,即1小時。如果任何嘗試均順利完成,則試用將終止。PkI28資訊網——每日最新資訊28at.com

由于定義了 SINGLE_TOPIC,因此將創建單個主題以進行重試。如果沒有進行此定義,則會創建 12 個重試主題。PkI28資訊網——每日最新資訊28at.com

如果拋出了排除中定義的任何錯誤,則不會執行重做。PkI28資訊網——每日最新資訊28at.com

如果需要,您可以編寫自己的 RetryableException 并在包含中定義此值,以便僅在引發此錯誤時才重試。PkI28資訊網——每日最新資訊28at.com

DLT隊列處理

如果完成了定義的嘗試次數并且繼續收到錯誤,則消息將發送到 DLT 隊列。如果要處理這些消息,可以使用DltHandler注解。PkI28資訊網——每日最新資訊28at.com

用法示例:PkI28資訊網——每日最新資訊28at.com

@DltHandler  public  void  handleDltMessage (RetryableDto retryableDto) {      log.error("DLT處理程序消息:{}", retryableDto); }

注意事項

雖然使用 RetryableTopic 的異步處理優勢為我們帶來了性能提升,但這種使用也有一些缺點。PkI28資訊網——每日最新資訊28at.com

使用RetryableTopic可能會破壞消息的處理順序。PkI28資訊網——每日最新資訊28at.com

讓我們用一個例子來解釋這種情況:當主主題在時間 t 處理時,一條消息出錯并被發送到重試主題。在時間 t + 1 時,另一條消息來到主主題并成功處理。讓我們在重試主題中的消息在時間 t + 2 時被成功處理。在這種情況下,第一條傳入消息將在第二條消息之后處理。如果訂購對您很重要,我建議您在消息處理過程中進行必要的檢查。PkI28資訊網——每日最新資訊28at.com

另一個缺點是消息雙重處理的風險。您可以通過考慮這種可能性來進行改進。PkI28資訊網——每日最新資訊28at.com

本文鏈接:http://www.www897cc.com/showinfo-26-57904-0.htmlSpring實現Kafka重試Topic,真的太香了

聲明:本網頁內容旨在傳播知識,若有侵權等問題請及時與本網聯系,我們將在第一時間刪除處理。郵件:2376512515@qq.com

上一篇: 應對ERP實施后面臨的挑戰的十個步驟

下一篇: 六種最關鍵的架構模式

標簽:
  • 熱門焦點
  • 紅魔電競平板評測:大屏幕硬實力

    前言:三年的疫情因為要上網課的原因激活了平板市場,如今網課的時代已經過去,大家的生活都恢復到了正軌,這也就意味著,真正考驗平板電腦生存的環境來了。也就是面對著這種殘酷的
  • 6月iOS設備好評榜:第一蟬聯榜首近一年

    作為安兔兔各種榜單里變化最小的那個,2023年6月的iOS好評榜和上個月相比沒有任何排名上的變化,僅僅是部分設備好評率的下降,長年累月的用戶評價和逐漸退出市場的老款機器讓這
  • 6月安卓手機好評榜:魅族20 Pro蟬聯冠軍

    性能榜和性價比榜之后,我們來看最后的安卓手機好評榜,數據來源安兔兔評測,收集時間2023年6月1日至6月30日,僅限國內市場。第一名:魅族20 Pro好評率:95%5月份的時候魅族20 Pro就是
  • 帥氣純真少年!日本最帥初中生選美冠軍出爐

    日本第一帥哥初一生選美大賽冠軍現已正式出爐,冠軍是來自千葉縣的宗田悠良。日本一直熱衷于各種選美大賽,從“最美JK”起到“最美女星&r
  • 讓我們一起聊聊文件的操作

    文件【1】文件是什么?文件是保存數據的地方,是數據源的一種,比如大家經常使用的word文檔、txt文件、excel文件、jpg文件...都是文件。文件最主要的作用就是保存數據,它既可以保
  • .NET 程序的 GDI 句柄泄露的再反思

    一、背景1. 講故事上個月我寫過一篇 如何洞察 C# 程序的 GDI 句柄泄露 文章,當時用的是 GDIView + WinDbg 把問題搞定,前者用來定位泄露資源,后者用來定位泄露代碼,后面有朋友反
  • JVM優化:實戰OutOfMemoryError異常

    一、Java堆溢出堆內存中主要存放對象、數組等,只要不斷地創建這些對象,并且保證 GC Roots 到對象之間有可達路徑來避免垃 圾收集回收機制清除這些對象,當這些對象所占空間超過
  • 每天一道面試題-CPU偽共享

    前言:了不起:又到了每天一到面試題的時候了!學弟,最近學習的怎么樣啊 了不起學弟:最近學習的還不錯,每天都在學習,每天都在進步! 了不起:那你最近學習的什么呢? 了不起學弟:最近在學習C
  • 三星Galaxy Z Fold/Flip 5國行售價曝光 :最低7499元/12999元起

    據官方此前宣布,三星將于7月26日也就是明天在韓國首爾舉辦Unpacked活動,屆時將帶來帶來包括Galaxy Buds 3、Galaxy Watch 6、Galaxy Tab S9、Galaxy
Top 主站蜘蛛池模板: 天等县| 灵山县| 临江市| 平阳县| 临西县| 辽宁省| 南漳县| 濮阳市| 张家口市| 龙山县| 南京市| 农安县| 买车| 抚州市| 久治县| 房山区| 乡城县| 嘉荫县| 清流县| 项城市| 耒阳市| 天津市| 荃湾区| 黎城县| 南涧| 旌德县| 黄浦区| 秭归县| 舒兰市| 策勒县| 娄底市| 深州市| 娱乐| 怀集县| 若羌县| 台安县| 桑日县| 武山县| 阳城县| 五原县| 五华县|