版权归本人所有,如果转载请联系本人 这篇大致说一下消息从写入到读取在Apache Pulsar服务端是怎么串起来的。( 这篇不会详细说明每个逻辑怎么走的,不过会给读者一个整体...
上一篇说到实际的核心逻辑是这2行代码 这里传递的参数将loadTopicsInBundle 设置了成true。我们看下在处理lookup请求过程中是否有loadtopic的逻...
简单逻辑说明通过topic名字确定namespace查找这个namespace的bundle分配信息根据bundle分配信息来确认这个topic属于哪个bundle根据bun...
pulsar 使用protocolBuf 作为二进制协议编写的工具 本文主要说明其中几个主要的RPC 的作用。并大致说一下这个几个RPC会被使用的位置。具体每个字段的含义会在...
主要成员变量 主要作用 可以读写ledger,维护ledger的位置(index) 保存ledger相关的metadata 支持checkpoint 写入Entry 写入会直...
简单梳理一下这个类的作用和逻辑。 主要功能 充当WAL 写请求处理:首先在Bookkeeper服务端收到了写Entry的请求之后会交给Bookie来处理Bookie.addE...
PulsarClient 让我们看一下这个类的主要方法 创建producer/consumer/reader 元数据信息相关 transaction相关 close方法 Cl...
1.启动入口 PulsarStandaloneStarter在standalone模式下,主要启动了以下几个服务 PulsarService PulsarAdmin Loca...
1. 前言 上次写Python操作LevelDB时提到过,有机会要实现下SkipList。摘录下wiki介绍: 跳跃列表是一种随机化数据结构,基于并联的链表,其效率可比拟二叉...