發(fā)簡信
IP屬地：上海
-
Apache Pulsar 多層抽象layer3-Broker緩存
每個(gè)Topic都有一個(gè)所屬的Broker，所以讀寫都是通過該Broker進(jìn)行的。這樣提供了很多的好處。 Broker可以將日志的尾部緩存在內(nèi)存中...
-
Apache Pulsar 多層抽象layer3-Bookie存儲(chǔ)Ledgers和Fragments是在Zookeeper中維護(hù)和跟蹤的邏輯結(jié)構(gòu)。物理上數(shù)據(jù)不存儲(chǔ)在Ledgers和Fragments對(duì)應(yīng)的文件中...
-
Apache Pulsar 多層抽象layer2-broker、Cursor追蹤broker簡介： pulsar broker是無狀態(tài)的，Bookeeper集群本身并不執(zhí)行復(fù)制，每個(gè)Bookies只是一個(gè)跟隨者被領(lǐng)導(dǎo)者同志做...
-
Apache Pulsar 多層抽象layer2-邏輯存儲(chǔ)體系Pulsar中的邏輯存儲(chǔ)體系使用的是Apache BookKeeper。本文僅在Pulsar的背景下介紹BookKeeper。 BookKeep...
-
Apache Pulsar 多層抽象layer1-Topic、Subscription和Cursors
參考：Apache Pulsar 消息傳遞模型(1)-消息模型Apache Pulsar 消息傳遞模型(2)-消息確認(rèn)Apache Pulsar...
-
Apache Pulsar 多層抽象概念
設(shè)計(jì)理念 保證不丟失消息(使用正確的配置且不是整個(gè)數(shù)據(jù)中心故障) 強(qiáng)順序性保證 可預(yù)測的讀寫延遲 Apache Pulsar選擇一致性而不是可用...
-
Apache Pulsar 消息傳遞模型(3)-消息保留與傳統(tǒng)的消息傳遞系統(tǒng)相比，消息在被確認(rèn)后不會(huì)立即被刪除。Pulsar在接收消息確認(rèn)時(shí)僅更新cursor,只有在所有訂閱已經(jīng)使用它之后才有可能刪除...
-
Apache Pulsar 消息傳遞模型(2)-消息確認(rèn)當(dāng)使用跨機(jī)器分布的消息傳遞系統(tǒng)時(shí)，可能會(huì)發(fā)生故障。在消費(fèi)者從消息傳遞系統(tǒng)中的主題消費(fèi)消息的情況下，消費(fèi)消息的消費(fèi)者和服務(wù)于主題分區(qū)的消息代理都可...
-
Apache Pulsar 消息傳遞模型(1)-消息模型1 消息消費(fèi) 目前的消息流式架構(gòu)中，消息用例被分為兩類：隊(duì)列和流 Apache Pulsar將隊(duì)列和流統(tǒng)一為消息傳遞模型：producer-to...