• Plusar 的核心概念

Topic
Bookie
Broker
Entry
Ledger
MetaData Storage
Journal

  • Plusar 的关键特性

跨地域复制 （geo-replication），单个实例原生支持多个集群 （跨集群复制）
极低的发布延迟和端到端延迟
可无缝扩展到超过100万个 topic
简单的客户端API，支持Java Gp Python C++
支持多种 topic 订阅模式：独占订阅、共享订阅、故障转移订阅、键共享（即 exclusive\shared\failover\key_shared）
通过Apache Bookkeeper 提供的持久化消息存储机制保证消息传递
由轻量级的无服务器（serverless） 计算框架 Pulsar Functions 实现流原生的数据处理
基于 Plusar Functions 的无服务器链接框架 Pluser IO使得数据更易接入、移出 
分层式存储可以在数据陈旧时，将数据从热存储卸载到冷/长期存储 （如S3 GCS）中

  • Plusar 的架构设计

一个Pulsar实例由一个或多个Plusar集群组成，实例中的集群可以在他们之间复制数据。一个 Pulsar cluster 有三部分组成：

一个或者多个 broker： 负责处理和负载均衡 producer 发出的消息，并将这些消息分派给 consumer；Broker 与 Plusar 配置存储交互来处理相应的任务，并将消息存储在 BookKeeper实例中（又称 bookies）; Broker 依赖 ZK 集群处理特定的任务

一个BookKeeper:包含一个或者多个 bookie 的BookKeeper集群负责消息的持久化存储

一个 ZooKeeper ： 特定于某个 Plusar 集群的ZK处理协调任务