参考文档
本部分参考文档详细介绍了构成 Spring for Apache Pulsar 的各个组件。
章节摘要
使用 Spring for Apache Pulsar
7 个项目
Topic 解析
生产或消费消息时需要目标 topic。框架会按以下顺序查找位置来确定 topic(找到第一个即停止):
默认租户/命名空间
Pulsar 内置了对多租户的支持。在 Pulsar 中生产或消费消息时,指定的 topic 实际上是一个 如下格式的 topic URL:
自定义 Object Mapper
Pulsar 在对 JSON 消息进行反序列化/序列化时使用内部 shaded 的 Jackson ObjectMapper。如果你希望改为提供自己的 Jackson 2 object mapper 实例,可以注册一个 SchemaResolverCustomizer 并按如下方式在 DefaultSchemaResolver 上设置你的 mapper:
Pulsar 管理
在 Pulsar 管理方面,Spring Boot 自动配置提供了一个 PulsarAdministration 来管理 Pulsar 集群。该管理组件实现了名为 PulsarAdminOperations 的接口,并提供 createOrModify 方法以通过其契约处理 topic 管理。
Pulsar Functions
Spring for Apache Pulsar 为 Pulsar IO(连接器)和 Pulsar Functions 提供基础支持,它们允许 用户定义由 source、processor 和 sink 组成的流处理管道。source 和 sink 由 Pulsar IO(连接器)建模,processor 由 Pulsar Functions 表示。
可观测性
Spring for Apache Pulsar 提供了一种通过 Micrometer 管理可观测性的方式。