目录
一、概述/Overview
二、消息/Messaging
三、架构/Architecture
四、客户端/Clients
五、地域复制/Geo Replication
六、多租户/Multi Tenancy
七、身份验证和授权/Authentication and Authorization
八、主题压缩/Topic Compaction
九、代理支持和SNI路由/Proxy support with SNI routing
十、多广播侦听器/Multiple advertised listeners
一、概述/Overview
Pulsar是一个多租户、高性能的服务器对服务器的消息传递解决方案。Originally developed by Yahoo, Pulsar is under the stewardship of the Apache Software Foundation.
Key features of Pulsar are listed below:
- 支持多集群(multiple clusters in a Pulsar instance),跨集群的无缝消息地域复制
- 极低的发布和端到端延迟(end-to-end latency)
- 无缝扩展到百万级别的主题数量(million topics)
- 使用简单的client API,A simple client API with bindings for Java, Go, Python and C++.
- 多订阅类型,Multiple subscription types (exclusive, shared, and failover) for topics.
- 由 Apache BookKeeper 保证持久消息的传递。
- 提供了无服务器的轻型计算框架 Pulsar Functions,可以处理流数据(stream-native data)。
- 提供无服务器的连接器框架 Pulsar IO,Pulsar IO 在 Pulsar Functions 基础上构建,可以更轻松地将数据移入和移出 Apache Pulsar。
- 分层存储(Tiered Storage),当数据老化时,分层存储将数据从热存储转移到冷存储(如S3和GCS)。
二、消息/Messaging
1、消息 Messaging
2、生产者 Producers
3、消费者 Consumers
4、主题 Topics
5、命名空间 Namespaces
6、消息订阅 Subscriptions
7、多主题订阅 Multi-topic subscriptions
8、主题分区 Partitioned topics
9、非持久化主题 Non-persistent topics
10、系统主题 System topic
11、消息传递 Message redelivery
12、消息保留和过期 Message retention and expiry
13、消息去重 Message deduplication
14、消息延迟传递
//如果连接失效,请在本专栏中找对应文章
三、架构/Architecture
pulsar 架构概述 Architecture Overview
四、客户端/Clients
Pulsar 客户端(Clients)
五、地域复制/Geo Replication
地域复制/Geo Replication
六、多租户/Multi Tenancy
Pulsar 多租户
七、身份验证和授权/Authentication and Authorization
Pulsar支持可插拔身份验证机制,该机制可在 proxy and/or the broker 上配置。Pulsar还支持可插拔授权机制。这些机制共同确定 client 及 client 对主题、命名空间和租户的访问权限。
// Java client API
八、主题压缩/Topic Compaction
主题压缩/Topic Compaction
九、代理支持和SNI路由/Proxy support with SNI routing
代理支持和SNI路由/Proxy support with SNI routing
十、多广播侦听器/Multiple advertised listeners
Pulsar 多播监听器