在Kafka中,每个topic被分成一个或多个partition,每个partition中的消息是有序且不可更改的。Partition是消息的逻辑单元,它可以分布在不同的broker上。
Rebalance机制是Kafka中用来维护消费者组内各个消费者之间负载均衡的机制。当新的消费者加入消费者组或者有消费者离开消费者组时,或者有新的topic被创建时,Kafka会触发Rebalance机制,重新分配各个消费者消费不同partition的消息,以保证各个消费者之间的负载均衡。在Rebalance过程中,Kafka会暂停消费,并重新分配partition,然后让消费者继续消费消息。
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
推荐阅读:Kafka中的Topic和Partition是什么