版权归本人所有，如果转载请联系本人 这篇大致说一下消息从写入到读取在Apache Pulsar服务端是怎么串起来的。( 这篇不会详细说明每个逻辑...
投稿
收录了8篇文章 · 6人关注
-
Apache Pulsar 源码走读（五）服务端消息流转逻辑概述
-
Apache Pulsar 源码走读（四）TopicLookup请求处理（二）
上一篇说到实际的核心逻辑是这2行代码 这里传递的参数将loadTopicsInBundle 设置了成true。我们看下在处理lookup请求过程...
-
Apache Pulsar 源码走读（三）TopicLookup 请求处理（一）
简单逻辑说明通过topic名字确定namespace查找这个namespace的bundle分配信息根据bundle分配信息来确认这个topic...
-
Apache Pulsar 源码走读（一）启动
1.启动入口 PulsarStandaloneStarter在standalone模式下，主要启动了以下几个服务 PulsarService P...
-
Apache Pulsar 源码走读（二）二进制协议pulsar 使用protocolBuf 作为二进制协议编写的工具 本文主要说明其中几个主要的RPC 的作用。并大致说一下这个几个RPC会被使用...
-
Apache Bookkeeper —— SingleDirectoryDBLedgerStorage
主要成员变量 主要作用 可以读写ledger，维护ledger的位置（index） 保存ledger相关的metadata 支持checkpoi...
-
Apache Bookkeeper —— Journal 源码分析
简单梳理一下这个类的作用和逻辑。 主要功能 充当WAL 写请求处理：首先在Bookkeeper服务端收到了写Entry的请求之后会交给Booki...
-
PulsarClient 解析(一）PulsarClient 让我们看一下这个类的主要方法 创建producer/consumer/reader 元数据信息相关 transacti...
专题公告
写一些pulsar 周边的文章，本人找工作中，有意私信。
{var%20f='http://v.t.sina.com.cn/share/share.php?appkey=1881139527',u=z||d.location,p=['&url=',e(u),'&title=',e(t||d.title),'&source=',e(r),'&sourceUrl=',e(l),'&content=',c||'gb2312','&pic=',e(p||'')].join('');function%20a(){if(!window.open([f,p].join(''),'mb',['toolbar=0,status=0,resizable=1,width=440,height=430,left=',(s.width-440)/2,',top=',(s.height-430)/2].join('')))u.href=[f,p].join('');};if(/Firefox/.test(navigator.userAgent))setTimeout(a,0);else%20a();})(screen,document,encodeURIComponent,'','','https://upload.jianshu.io/collections/images/1936212/%E6%88%AA%E5%B1%8F2021-01-04_%E4%B8%8B%E5%8D%888.45.14.png', '推荐专题《Apache Pulsar 指南》（ 分享自 @简书 ）','https://jianshuapi.com/c/e1e50598059b?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','页面编码gb2312|utf-8默认gb2312'));){kind=link}