发简信
IP属地：北京
-
Apache Pulsar 源码走读（五）服务端消息流转逻辑概述
版权归本人所有，如果转载请联系本人 这篇大致说一下消息从写入到读取在Apache Pulsar服务端是怎么串起来的。( 这篇不会详细说明每个逻辑...
-
Apache Pulsar 源码走读（四）TopicLookup请求处理（二）
上一篇说到实际的核心逻辑是这2行代码 这里传递的参数将loadTopicsInBundle 设置了成true。我们看下在处理lookup请求过程...
-
Apache Pulsar 源码走读（三）TopicLookup 请求处理（一）
简单逻辑说明通过topic名字确定namespace查找这个namespace的bundle分配信息根据bundle分配信息来确认这个topic...
-
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...
-
Apache Pulsar 源码走读（一）启动
1.启动入口 PulsarStandaloneStarter在standalone模式下，主要启动了以下几个服务 PulsarService P...
-
FLIP-6 Flink runtime设计文档摘要（一）这篇主要是组件的职责和功能 每个JobManager负责一个Job，在提交JobGraph时创建，在job完成后销毁 JobManager同样可...