参考
本部分参考文档详细介绍了构成 Spring for Apache Pulsar 的各个组件。
章节摘要
🗃️ 使用 Spring for Apache Pulsar
7 个项目
🗃️ Reactive 支持
6 个项目
📄️ 主题解析
在生成或消费消息时,需要一个目标主题。框架按照以下顺序位置来确定主题(在第一次找到时停止):
📄️ 默认租户 / 命名空间
Pulsar 内置支持多租户。在 Pulsar 中生产和消费消息时,指定的主题实际上是一个具有以下格式的主题 URL:
📄️ 自定义对象映射器
Pulsar 使用内部的 Jackson ObjectMapper 来进行 JSON 消息的序列化和反序列化。如果你想提供自己的对象映射实例,可以注册一个 SchemaResolverCustomizer,并在 DefaultSchemaResolver 上设置你的映射器,如下所示:
📄️ Pulsar 管理
在 Pulsar 管理端,Spring Boot 自动配置提供了一个 PulsarAdministration 来管理 Pulsar 集群。该管理实现了一个名为 PulsarAdminOperations 的接口,并提供了一个 createOrModify 方法,通过其契约处理主题管理。
📄️ Pulsar 函数
Spring for Apache Pulsar 提供了对 Pulsar IO(连接器)和 Pulsar Functions 的基本支持,允许用户定义由源、处理器和接收器组成的流处理管道。源和接收器由 Pulsar IO(连接器)建模,而处理器则由 Pulsar Functions 表示。
📄️ 可观测性
Spring for Apache Pulsar 提供了一种通过 Micrometer 管理可观测性的方式。