kafka設置隊列優先級?
將優先級統一設定為高、中、低三個級別。具體操作方案如下:
1. 對某個優先級根據 task (單次推送任務)維度,存入不同的 Topic,一個 task 只寫入一個 Topic,一個 Topic 可存多個 task;2. 消費模塊根據優先級配額(如 6:3:1),獲取不同優先級的消息數,同一優先級輪詢獲取消息;這樣既保證了高優先級用戶可以更快地發送消息,又避免了低優先級用戶出現沒有下發的情況。kafka設置隊列優先級?
將優先級統一設定為高、中、低三個級別。具體操作方案如下:
1. 對某個優先級根據 task (單次推送任務)維度,存入不同的 Topic,一個 task 只寫入一個 Topic,一個 Topic 可存多個 task;2. 消費模塊根據優先級配額(如 6:3:1),獲取不同優先級的消息數,同一優先級輪詢獲取消息;這樣既保證了高優先級用戶可以更快地發送消息,又避免了低優先級用戶出現沒有下發的情況。