??在kafka中，副本分成兩種:一種是領(lǐng)導(dǎo)者副本，每個(gè)partition只有一個(gè)；還有一種是追隨者副本，每個(gè)partition會(huì)存在多個(gè)。領(lǐng)導(dǎo)者副本負(fù)責(zé)響應(yīng)生產(chǎn)者和消費(fèi)者的...
發(fā)簡信
IP屬地：西藏
-
說說Kafka的追隨者副本為什么不對外提供服務(wù) -
兩階段提交（2PC）與其在Flink exactly once中的應(yīng)用前言 簡書快正式從小黑屋里出來了，所以是時(shí)候重啟更新了。這段時(shí)間積攢了不少要寫的東西，逐個(gè)擊破吧。 兩階段提交（two-phase commit, 2PC）是最基礎(chǔ)的分布式一...
-
本博客所有內(nèi)容均適用知識(shí)共享-署名-相同方式共享（CC-BY-SA）4.0協(xié)議。
-
2019-11-06 kafka數(shù)據(jù)保存時(shí)間的設(shè)置
kafka默認(rèn)的只保存7天的數(shù)據(jù)，時(shí)間一到就刪除數(shù)據(jù)，當(dāng)遇到磁盤過小，，存放的數(shù)據(jù)量過大，可以設(shè)置縮短這個(gè)時(shí)間。 設(shè)置全局配置 對單獨(dú)的某一個(gè)topic設(shè)置過期的時(shí)間 查看設(shè)...
-
哎,這個(gè)東西把我坑壞了,以前老師給布置的一個(gè)作業(yè),我以為很簡單呢,結(jié)果今天嘗試了一晚上,而且上網(wǎng)也搜不到錯(cuò)誤.....
flume同時(shí)使用KafkaSource、KafkaSink導(dǎo)致的問題
KafkaSource 配置topic：topic1KafkaSink 配置topic：topic2從topic1拉取數(shù)據(jù)，經(jīng)過簡單處理后發(fā)到topic2但是你會(huì)發(fā)現(xiàn)flum...
