kafka leader平衡策略


1.1個partition的默認leader是replicas中的第一個replica
2.kafka controller會啟動一個定時的check線程,kafka默認是5min周期,mafka是30min周期。去check當前的leader信息
3.該線程的工作原理: controller check每台alive的broker當前的元數據信息中的partition的leader信息,然后和默認的leader(1)的值進行比較,求出imbalanceRatio(比例)。
4.比較發現這個比例超過10%(kafka默認),則進行rebalance


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM