發(fā)簡(jiǎn)信
IP屬地：黑龍江
下面我們來介紹下Kafka rebalance的原理。kafka的consumer group有多個(gè)consumer實(shí)例，這些consumer實(shí)...
下面我們來介紹下Kafka怎么調(diào)優(yōu)可用性相關(guān)的參數(shù)。可用性反映的是kafka集群應(yīng)對(duì)崩潰的能力。無論broker,producer,consum...
下面我們來介紹下Kafka怎么調(diào)優(yōu)延遲時(shí)間相關(guān)的參數(shù)。對(duì)于kafka的不同組件，延遲時(shí)間的意義是不同的。對(duì)于producer來說，延遲時(shí)間主要是...
下面我們來介紹下Kafka怎么調(diào)優(yōu)吞吐量相關(guān)的參數(shù)，首先我們需要確定當(dāng)我們想要調(diào)優(yōu)kafka的時(shí)候，我們需要從哪些方面開始呢，一般來說，我們需要...
下面我們來介紹下Kafka怎么保證消息的可靠性，在消息中間件里，有一個(gè)非常重要的問題就是怎么保證消息不丟失，而這就是消息的可靠性問題。在介紹Ka...
下面我們來說一下Kafka是怎么處理日志的。Kafka中的日志就像數(shù)據(jù)庫中的記錄，或者是commit log一樣的日志，是按照時(shí)間順序?qū)懭氲?，?..
下面我們來進(jìn)行consumer的開發(fā)。先來寫一個(gè)Consumer類，在構(gòu)造方法里初始化KafkaConsumer對(duì)象，并設(shè)置相應(yīng)的參數(shù)。 Kaf...
下面我們來實(shí)際的使用一下Kafka，看一下是怎么進(jìn)行消息的生產(chǎn)的。我們先新建一個(gè)類Producer，在構(gòu)造方法中初始化KafkaProducer...
下面我們來說一下Kafka的集群管理。我們知道Kafka的高可用是通過集群的方式實(shí)現(xiàn)的，那么集群管理是怎么實(shí)現(xiàn)的呢？簡(jiǎn)單來說，Kafka的集群管...