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

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

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過(guò)程會(huì)對(duì)consumer group產(chǎn)生非常嚴(yán)重的影響，Rebalance的過(guò)程中所有的消費(fèi)者都將停止工作，直到Rebalance完成。

最新資訊