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