默认租户/命名空间
Pulsar 内置了对多租户的支持。在 Pulsar 中生成或消费消息时,指定的 topic 实际上是以下格式的 topic URL:
(persistent|non-persistent)://tenant/namespace/topic
URL 指示作针对哪个租户和命名空间。但是,如果不是完全限定的(即仅指定主题名称),则默认租户public
和命名空间default
被使用。
Spring for Apache Pulsar 允许您指定在针对非完全限定主题 URL 生成或使用消息时要使用的默认租户和/或命名空间。
配置
使用 Spring Boot
使用 Spring Boot 时,您可以简单地将spring.pulsar.defaults.topic.tenant
和spring.pulsar.defaults.topic.namespace
应用程序属性来指定这些默认值。
如果您想禁用此功能,只需将spring.pulsar.defaults.topic.enabled
属性设置为false
.
没有 Spring Boot
但是,如果您改为手动配置组件,则必须提供PulsarTopicBuilder
在构造相应的生产者或消费者工厂时配置所需的默认主题和命名空间。所有默认的消费者/读取器/生产者工厂实现(命令式和响应式)都允许指定主题构建器。
您需要在要使用默认租户/命名空间的每个手动配置的工厂上指定主题构建器 |