發(fā)簡信
IP屬地：北京
-
Apache Pulsar 源碼走讀（五）服務(wù)端消息流轉(zhuǎn)邏輯概述
版權(quán)歸本人所有，如果轉(zhuǎn)載請聯(lián)系本人 這篇大致說一下消息從寫入到讀取在Apache Pulsar服務(wù)端是怎么串起來的。( 這篇不會詳細說明每個邏輯...
-
Apache Pulsar 源碼走讀（四）TopicLookup請求處理（二）
上一篇說到實際的核心邏輯是這2行代碼 這里傳遞的參數(shù)將loadTopicsInBundle 設(shè)置了成true。我們看下在處理lookup請求過程...
-
Apache Pulsar 源碼走讀（三）TopicLookup 請求處理（一）
簡單邏輯說明通過topic名字確定namespace查找這個namespace的bundle分配信息根據(jù)bundle分配信息來確認這個topic...
-
Apache Pulsar 源碼走讀（二）二進制協(xié)議pulsar 使用protocolBuf 作為二進制協(xié)議編寫的工具 本文主要說明其中幾個主要的RPC 的作用。并大致說一下這個幾個RPC會被使用...
-
Apache Bookkeeper —— SingleDirectoryDBLedgerStorage
主要成員變量 主要作用 可以讀寫ledger，維護ledger的位置（index） 保存ledger相關(guān)的metadata 支持checkpoi...
-
Apache Bookkeeper —— Journal 源碼分析
簡單梳理一下這個類的作用和邏輯。 主要功能 充當WAL 寫請求處理：首先在Bookkeeper服務(wù)端收到了寫Entry的請求之后會交給Booki...
-
PulsarClient 解析(一）PulsarClient 讓我們看一下這個類的主要方法 創(chuàng)建producer/consumer/reader 元數(shù)據(jù)信息相關(guān) transacti...
-
Apache Pulsar 源碼走讀（一）啟動
1.啟動入口 PulsarStandaloneStarter在standalone模式下，主要啟動了以下幾個服務(wù) PulsarService P...
-
FLIP-6 Flink runtime設(shè)計文檔摘要（一）這篇主要是組件的職責和功能 每個JobManager負責一個Job，在提交JobGraph時創(chuàng)建，在job完成后銷毀 JobManager同樣可...