1
消息队列：Pulsar：Pulsar 的 Topic 管理与操作
1 消息队列：Pulsar：Pulsar 的 Topic 管理与操作
1.1 Pulsar 基础概念
1.1.1 Pulsar 架构简介
Apache Pulsar 是一个分布式消息和流平台，提供消息队列和流处理功能。
它由以下主要组件构成：
� Broker：负责消息的路由和管理，处理客户端的请求。
� ZooKeeper：用于存储集群的元数据，如 topic 的配置和状态。
� BookKeeper：提供持久化存储，确保消息的可靠存储和传输。
� Function Worker：执行流处理和数据处理任务。
� Pulsar Manager：提供管理界面和 API，用于监控和管理 Pulsar 集
群。
Pulsar 的设计使其能够支持高吞吐量、低延迟和大规模的分布式部署，同
时保证消息的持久性和一致性。
1.1.2 Topic 与 Subscription 的基本理解
在 Pulsar 中，Topic 是消息的发布和订阅的基本单位。一个 topic 可以有多
个生产者和消费者，生产者向 topic 发布消息，消费者从 topic 订阅消息。Topic
可以是持久的或非持久的，持久 topic 的消息会被存储在 BookKeeper 上，非持
久 topic 的消息则不会被存储。
Subscription 是消费者对 topic 的订阅，一个 topic 可以有多个 subscription，
每个 subscription 可以有多个消费者。Subscription 有以下几种类型：
� Exclusive：只有一个消费者可以订阅，其他消费者将无法订阅。
� Shared：多个消费者可以订阅，消息会被均匀地分发给所有消费
者。
� Failover：多个消费者可以订阅，但一次只有一个消费者可以接收
消息，如果当前消费者失败，消息将被传递给下一个消费者。
� Key_Shared：基于消息的 key 进行分发，相同 key 的消息会被发
送给同一个消费者。
� Sticky：类似于 Shared，但消息分发策略更复杂，可以基于消费者
的状态进行优化。
剩余18页未读，继续阅读
资源评论
