![240](https://upload.jianshu.io/users/upload_avatars/14842596/d0ee622c-62cd-415e-8565-545f64be1d4a.png?imageMogr2/auto-orient/strip|imageView2/1/w/240/h/240)
下面我們來介紹下Kafka rebalance的原理眠寿。kafka的consumer group有多個consumer實例匾嘱,這些consumer實...
下面我們來介紹下Kafka怎么調(diào)優(yōu)可用性相關(guān)的參數(shù)鹦马∫逼ィ可用性反映的是kafka集群應(yīng)對崩潰的能力贴捡。無論broker,producer,consum...
下面我們來介紹下Kafka怎么調(diào)優(yōu)延遲時間相關(guān)的參數(shù)曙聂。對于kafka的不同組件罚屋,延遲時間的意義是不同的苦囱。對于producer來說,延遲時間主要是...
下面我們來介紹下Kafka怎么調(diào)優(yōu)吞吐量相關(guān)的參數(shù)脾猛,首先我們需要確定當我們想要調(diào)優(yōu)kafka的時候撕彤,我們需要從哪些方面開始呢,一般來說猛拴,我們需要...
下面我們來介紹下Kafka怎么保證消息的可靠性羹铅,在消息中間件里,有一個非常重要的問題就是怎么保證消息不丟失愉昆,而這就是消息的可靠性問題职员。在介紹Ka...
下面我們來說一下Kafka是怎么處理日志的。Kafka中的日志就像數(shù)據(jù)庫中的記錄跛溉,或者是commit log一樣的日志焊切,是按照時間順序?qū)懭氲模?..
下面我們來進行consumer的開發(fā)芳室。先來寫一個Consumer類专肪,在構(gòu)造方法里初始化KafkaConsumer對象,并設(shè)置相應(yīng)的參數(shù)堪侯。 Kaf...
下面我們來實際的使用一下Kafka嚎尤,看一下是怎么進行消息的生產(chǎn)的。我們先新建一個類Producer伍宦,在構(gòu)造方法中初始化KafkaProducer...
下面我們來說一下Kafka的集群管理芽死。我們知道Kafka的高可用是通過集群的方式實現(xiàn)的,那么集群管理是怎么實現(xiàn)的呢次洼?簡單來說关贵,Kafka的集群管...