下面我們來(lái)介紹下Kafka rebalance的原理薄榛。kafka的consumer group有多個(gè)consumer實(shí)例齿尽，這些consumer實(shí)...

下面我們來(lái)介紹下Kafka怎么調(diào)優(yōu)可用性相關(guān)的參數(shù)布卡〕ü保可用性反映的是kafka集群應(yīng)對(duì)崩潰的能力盒刚。無(wú)論broker,producer,consum...

下面我們來(lái)介紹下Kafka怎么調(diào)優(yōu)延遲時(shí)間相關(guān)的參數(shù)掀淘。對(duì)于kafka的不同組件砚亭，延遲時(shí)間的意義是不同的曾棕。對(duì)于producer來(lái)說(shuō)扣猫，延遲時(shí)間主要是...

下面我們來(lái)介紹下Kafka怎么調(diào)優(yōu)吞吐量相關(guān)的參數(shù)，首先我們需要確定當(dāng)我們想要調(diào)優(yōu)kafka的時(shí)候翘地，我們需要從哪些方面開(kāi)始呢申尤，一般來(lái)說(shuō)，我們需要...

下面我們來(lái)介紹下Kafka怎么保證消息的可靠性衙耕，在消息中間件里昧穿，有一個(gè)非常重要的問(wèn)題就是怎么保證消息不丟失，而這就是消息的可靠性問(wèn)題橙喘。在介紹Ka...

下面我們來(lái)說(shuō)一下Kafka是怎么處理日志的时鸵。Kafka中的日志就像數(shù)據(jù)庫(kù)中的記錄，或者是commit log一樣的日志厅瞎，是按照時(shí)間順序?qū)懭氲氖吻保?..

下面我們來(lái)進(jìn)行consumer的開(kāi)發(fā)。先來(lái)寫(xiě)一個(gè)Consumer類(lèi)和簸，在構(gòu)造方法里初始化KafkaConsumer對(duì)象彭雾，并設(shè)置相應(yīng)的參數(shù)。 Kaf...

下面我們來(lái)實(shí)際的使用一下Kafka锁保，看一下是怎么進(jìn)行消息的生產(chǎn)的薯酝。我們先新建一個(gè)類(lèi)Producer南誊，在構(gòu)造方法中初始化KafkaProducer...

下面我們來(lái)說(shuō)一下Kafka的集群管理。我們知道Kafka的高可用是通過(guò)集群的方式實(shí)現(xiàn)的蜜托，那么集群管理是怎么實(shí)現(xiàn)的呢抄囚？簡(jiǎn)單來(lái)說(shuō)，Kafka的集群管...