在Kafka中,每個topic被分成一個或多個partition,每個partition中的消息是有序且不可更改的。Partition是消息的邏輯單元,它可以分布在不同的broker上。
Rebalance機制是Kafka中用來維護消費者組內各個消費者之間負載均衡的機制。當新的消費者加入消費者組或者有消費者離開消費者組時,或者有新的topic被創建時,Kafka會觸發Rebalance機制,重新分配各個消費者消費不同partition的消息,以保證各個消費者之間的負載均衡。在Rebalance過程中,Kafka會暫停消費,并重新分配partition,然后讓消費者繼續消費消息。