發(fā)簡(jiǎn)信
IP屬地：吉林
下面我們來(lái)介紹下Kafka rebalance的原理。kafka的consumer group有多個(gè)consumer實(shí)例，這些consumer實(shí)...
下面我們來(lái)介紹下Kafka怎么調(diào)優(yōu)可用性相關(guān)的參數(shù)?？捎眯苑从车氖莐afka集群應(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類，在構(gòu)造方法里初始化KafkaConsumer對(duì)象，并設(shè)置相應(yīng)的參數(shù)。 Kaf...
下面我們來(lái)實(shí)際的使用一下Kafka，看一下是怎么進(jìn)行消息的生產(chǎn)的。我們先新建一個(gè)類Producer，在構(gòu)造方法中初始化KafkaProducer...
下面我們來(lái)說(shuō)一下Kafka的集群管理。我們知道Kafka的高可用是通過(guò)集群的方式實(shí)現(xiàn)的，那么集群管理是怎么實(shí)現(xiàn)的呢？簡(jiǎn)單來(lái)說(shuō)，Kafka的集群管...