K60至尊版剛預(yù)熱 一加Ace2 Pro正面硬剛
Redmi這邊剛?cè)缁鹑巛钡男麄髁薑60 Ultra的各種技術(shù)和硬件配置，作為競(jìng)品的一加也坐不住了。一加中國(guó)區(qū)總裁李杰發(fā)布了兩條微博，表示在自家的一加Ace2上早就已經(jīng)采用了和PixelWo
Kafka的強(qiáng)大功能之一是每個(gè)分區(qū)都有一個(gè)Consumer的偏移值。該偏移值是消費(fèi)者將讀取的下一條消息的值。可以自動(dòng)或手動(dòng)增加該值。如果我們由于錯(cuò)誤而無(wú)法處理消息并想重試，我們可以選擇手動(dòng)管理，并在成功的情況下增加偏移量。但是，這會(huì)暫時(shí)阻止隊(duì)列消息的處理。我們可以選擇異步方法。
如果發(fā)生錯(cuò)誤，而不是停止隊(duì)列消息的處理；我們可以將錯(cuò)誤消息轉(zhuǎn)移到不同的主題并再次處理。
如果在處理 Kafka 消息時(shí)出現(xiàn)錯(cuò)誤，可以使用 RetryableTopic 注解以一定的時(shí)間間隔和一定的次數(shù)再次處理消息。如果完成嘗試次數(shù)后錯(cuò)誤仍然存在，則消息將發(fā)送到 DLT 隊(duì)列。
我們首先回顧一下RetryableTopic注解可以取的一些值，以便您可以做出最適合您的設(shè)置：
attempts：嘗試處理消息的次數(shù)。它的默認(rèn)值為 3。如果完成所有嘗試后仍然收到錯(cuò)誤，則消息將發(fā)送到 DLT 隊(duì)列。
backoff：用于確定處理消息的時(shí)間間隔。從 Backoff 類(lèi)獲取一個(gè)值。您可以在下面找到退避的詳細(xì)示例。
排除/排除名稱(chēng)：允許您排除指定的異常類(lèi)。當(dāng)您添加到列表中的任何錯(cuò)誤被拋出時(shí)，重試機(jī)制將不會(huì)被激活。
include / includeNames：僅當(dāng)拋出指定的異常時(shí)才會(huì)激活重試機(jī)制。
kafkaTemplate：雖然您可以給出現(xiàn)有 kafkaTemplate bean 的名稱(chēng)，但您也可以為特定于重試的 Kafka 模板定義不同的 bean。
autoCreateTopics：決定是否自動(dòng)創(chuàng)建Retry和DLT主題。
retryTopicSuffix / dltTopicSuffix：用于確定要添加到自動(dòng)創(chuàng)建的主題末尾的后綴。
dltStrategy：如果不需要DLT，可以定義為NO_DLT。
SameIntervalTopicReuseStrategy/fixedDelayTopicStrategy（3.0.4之前）：用于確定要?jiǎng)?chuàng)建的重試主題策略。創(chuàng)建 (SINGLE_TOPIC) 或盡可能多的嘗試值 (MULTIPLE_TOPICS) 重試主題。
Backoff(delay = 600000 ) // 每 10 分鐘Backoff(delay = 60000 , multiplier = 2 ) // 1、2、4、8... 分鐘后重復(fù)。Backoff(delayExpression = "${delay}", multiplierExpression = "${multiplier}")@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小時(shí)。如果任何嘗試均順利完成，則試用將終止。
由于定義了 SINGLE_TOPIC，因此將創(chuàng)建單個(gè)主題以進(jìn)行重試。如果沒(méi)有進(jìn)行此定義，則會(huì)創(chuàng)建 12 個(gè)重試主題。
如果拋出了排除中定義的任何錯(cuò)誤，則不會(huì)執(zhí)行重做。
如果需要，您可以編寫(xiě)自己的 RetryableException 并在包含中定義此值，以便僅在引發(fā)此錯(cuò)誤時(shí)才重試。
如果完成了定義的嘗試次數(shù)并且繼續(xù)收到錯(cuò)誤，則消息將發(fā)送到 DLT 隊(duì)列。如果要處理這些消息，可以使用DltHandler注解。
用法示例：
@DltHandler public void handleDltMessage (RetryableDto retryableDto) { log.error("DLT處理程序消息：{}", retryableDto); }雖然使用 RetryableTopic 的異步處理優(yōu)勢(shì)為我們帶來(lái)了性能提升，但這種使用也有一些缺點(diǎn)。
使用RetryableTopic可能會(huì)破壞消息的處理順序。
讓我們用一個(gè)例子來(lái)解釋這種情況：當(dāng)主主題在時(shí)間 t 處理時(shí)，一條消息出錯(cuò)并被發(fā)送到重試主題。在時(shí)間 t + 1 時(shí)，另一條消息來(lái)到主主題并成功處理。讓我們?cè)谥卦囍黝}中的消息在時(shí)間 t + 2 時(shí)被成功處理。在這種情況下，第一條傳入消息將在第二條消息之后處理。如果訂購(gòu)對(duì)您很重要，我建議您在消息處理過(guò)程中進(jìn)行必要的檢查。
另一個(gè)缺點(diǎn)是消息雙重處理的風(fēng)險(xiǎn)。您可以通過(guò)考慮這種可能性來(lái)進(jìn)行改進(jìn)。
本文鏈接：http://www.tebozhan.com/showinfo-26-57904-0.htmlSpring實(shí)現(xiàn)Kafka重試Topic，真的太香了
聲明：本網(wǎng)頁(yè)內(nèi)容旨在傳播知識(shí)，若有侵權(quán)等問(wèn)題請(qǐng)及時(shí)與本網(wǎng)聯(lián)系，我們將在第一時(shí)間刪除處理。郵件：2376512515@qq.com
Copyright ? 2016-2023 天津谷騏科技有限公司 版權(quán)所有 sitemap.xml
違法及侵權(quán)請(qǐng)聯(lián)系：2376512515@qq.com 津ICP備18001702號(hào)
津公網(wǎng)安備 12010102000574號(hào)