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