我在kafka消息處理中有一個場景,其中我得到了3種類型的負(fù)載:category_createfolder_createarticle_create為此,我在DB中輸入理想情況下,加載應(yīng)按順序進行:category_create -> folder_create -> article_create,因為文件夾始終屬于某個類別,文章始終屬于某個文件夾。對于folder_create處理文件夾的類別,應(yīng)該已經(jīng)作為kafka消息接收。但是,在某些情況下,folder_create負(fù)載在category_create之前幾毫秒。我可以在彈簧靴中做些什么來等待毫秒,以防folder_create允許category_create處理,然后處理folder_create。嘗試在彈簧靴中使用@Retry和@Recover,但我想這不適合這種情況。
卡夫卡無序消息場景處理
慕田峪4524236
2022-08-03 10:25:36