??在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ā)簡(jiǎn)信
IP屬地：山東
-
說(shuō)說(shuō)Kafka的追隨者副本為什么不對(duì)外提供服務(wù) -
兩階段提交（2PC）與其在Flink exactly once中的應(yīng)用前言 簡(jiǎn)書快正式從小黑屋里出來(lái)了但骨，所以是時(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)遇到磁盤過(guò)小贬蛙，雨女，存放的數(shù)據(jù)量過(guò)大，可以設(shè)置縮短這個(gè)時(shí)間阳准。 設(shè)置全局配置 對(duì)單獨(dú)的某一個(gè)topic設(shè)置過(guò)期的時(shí)間 查看設(shè)...
-
哎,這個(gè)東西把我坑壞了,以前老師給布置的一個(gè)作業(yè),我以為很簡(jiǎn)單呢,結(jié)果今天嘗試了一晚上,而且上網(wǎng)也搜不到錯(cuò)誤.....
flume同時(shí)使用KafkaSource野蝇、KafkaSink導(dǎo)致的問(wèn)題
KafkaSource 配置topic：topic1KafkaSink 配置topic：topic2從topic1拉取數(shù)據(jù)讼稚，經(jīng)過(guò)簡(jiǎn)單處理后發(fā)到topic2但是你會(huì)發(fā)現(xiàn)flum...
