你可能并不懂 Apache Pulsar 的消息存储模型

…

未设置 msg key，消息会以 round robin 的形式，分发到不同的 partitions 中

在消息分发的模型中，Pulsar 与 Kafka 类似。

Key_Shared

Node: 在 Bookkeeper 中，对数据操作的最小单元是按照 segment 这个粒度来进行操作的。

Subscription Backlog: 指针对单个订阅级别的没有消费的数据的集合

如下图所示：Backlog A 属于 Topic Backlog；Backlog A 属于 Subscription-1 Backlog；Backlog B 属于 Subscription-2 的 Backlog。

backlogSize：记录的是所有没有被 Ack 的消息的大小

time：指持久化时间的阈值。0 代表不配置 Retention 时间策略，-1 代表时间无限大

在引入 Retention 策略之后，整个 Topic 表示的视图如下所示，m0-m5 代表已经被所有订阅确认的消息并且已经超过了 Retention 策略的阈值，即这些消息正在 准备删除。注意，我这里描述的是 【准备删除】具体是否可以被删除，现在还不能确定。

本文分享自微信公众号 - 腾讯云中间件（gh_6ea1bc2dd5fd）。
如有侵权，请联系 [e-mail] 删除。
本文参与“OSC源创计划”，欢迎正在阅读的你也加入，一起分享。