Topic Compaction

    Pulsar的topic压缩特性:

    • 仅适用于
    • Triggered automatically when the backlog reaches a certain size or can be triggered manually via the command line. See the Topic compaction cookbook

    Topic压缩示例:股票报价机

    通过命令行触发topic压缩,Pulsar将会从头到尾迭代整个topic。 对于它碰到的每个key,压缩程序将会只保留这个key最近的事件。

    初始化压缩操作完成后,将来任何对压缩层位及压缩backlog的修改,都会通知给拥有该topic的Pulsar 。 当下列更改发生时:

    • 启用读取压缩功能的客户端(consumer和reader),将会尝试从topic中读取消息,或者:
      • 像从正常的主题那样读取(如果消息的ID大于等于压缩层位),或