馬老師tomcat源碼
? ?Kafka從0.8開(kāi)始提供partition級(jí)別的replication,replication的數(shù)量可在$KAFKA_HOME/config/server.properties中配置。
該 Replication與leader election配合提供了自動(dòng)的failover機(jī)制。replication對(duì)Kafka的吞吐率是有一定影響的,但極大的增強(qiáng)了可用性。默認(rèn)情況下,Kafka的replication數(shù)量為1。 每個(gè)partition都有一個(gè)唯一的leader,所有的讀寫(xiě)操作都在leader上完成,leader批量從leader上pull數(shù)據(jù)。一般情況下partition的數(shù)量大于等于broker的數(shù)量,并且所有partition的leader均勻分布在broker上。follower上的日志和其leader上的完全一樣。
和大部分分布式系統(tǒng)一樣,Kakfa處理失敗需要明確定義一個(gè)broker是否alive。對(duì)于Kafka而言
標(biāo)簽: