教育行業(yè)A股IPO第一股(股票代碼 003032)

全國咨詢/投訴熱線:400-618-4000

什么是Rebalanc?Rebalance觸發(fā)時機(jī)有哪些?

更新時間:2022年08月12日15時36分 來源:傳智教育 瀏覽次數(shù):


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

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

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

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

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

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

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

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

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

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

Rebalance的不良影響

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

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


0 分享到:
和我們在線交談!