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大于等于压缩层位),或