消息队列：Pulsar：Pulsar的Topic管理与操作.docx资源-CSDN文库

版权申诉

128 浏览量 2024-09-02 20:10:33 上传评论收藏 32KB DOCX 举报

资源推荐

资源详情

资源评论

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页未读，继续阅读

内容反馈

版权申诉

kkchenjj

粉丝: 2w+
资源: 5480

最新资源

资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！点击此处反馈

feedback-tip