首頁技術(shù)文章正文

哪種情況下會(huì)觸發(fā)Rebalance再均衡?

更新時(shí)間:2022-08-12 來源:黑馬程序員 瀏覽量:

IT培訓(xùn)班


Kafka中的Rebalance稱之為再均衡,是Kafka中確保Consumer group下所有的consumer如何達(dá)成一致,分配訂閱的topic的每個(gè)分區(qū)的機(jī)制。

Rebalance觸發(fā)的時(shí)機(jī)有:

1.消費(fèi)者組中consumer的個(gè)數(shù)發(fā)生變化

例如:有新的consumer加入到消費(fèi)者組,或者是某個(gè)consumer停止了。

Rebalance的觸發(fā)機(jī)制

2. 訂閱的topic個(gè)數(shù)發(fā)生變化

消費(fèi)者可以訂閱多個(gè)主題,假設(shè)當(dāng)前的消費(fèi)者組訂閱了三個(gè)主題,但有一個(gè)主題突然被刪除了,此時(shí)也需要發(fā)生再均衡。

訂閱的topic個(gè)數(shù)發(fā)生變化

3.訂閱的topic分區(qū)數(shù)發(fā)生變化

訂閱的topic分區(qū)數(shù)發(fā)生變化

Rebalance的不良影響

1.發(fā)生Rebalance時(shí),consumer group下的所有consumer都會(huì)協(xié)調(diào)在一起共同參與,Kafka使用分配策略盡可能達(dá)到最公平的分配。

2. Rebalance過程會(huì)對(duì)consumer group產(chǎn)生非常嚴(yán)重的影響,Rebalance的過程中所有的消費(fèi)者都將停止工作,直到Rebalance完成。

分享到:
在線咨詢 我要報(bào)名
和我們?cè)诰€交談!