版权归本人所有，如果转载请联系本人 这篇大致说一下消息从写入到读取在Apache Pulsar服务端是怎么串起来的...[作者空间]
上一篇说到实际的核心逻辑是这2行代码 这里传递的参数将loadTopicsInBundle 设置了成true。我们...[作者空间]
简单逻辑说明通过topic名字确定namespace查找这个namespace的bundle分配信息根据bundl...[作者空间]
pulsar 使用protocolBuf 作为二进制协议编写的工具 本文主要说明其中几个主要的RPC 的作用。并大...[作者空间]
主要成员变量 主要作用 可以读写ledger，维护ledger的位置（index） 保存ledger相关的meta...[作者空间]
简单梳理一下这个类的作用和逻辑。 主要功能 充当WAL 写请求处理：首先在Bookkeeper服务端收到了写Ent...[作者空间]
PulsarClient 让我们看一下这个类的主要方法 创建producer/consumer/reader 元数...[作者空间]
1.启动入口 PulsarStandaloneStarter在standalone模式下，主要启动了以下几个服务 ...[作者空间]
