什么是新内容？

最新更新 in 1.2 自 1.1

本部分涵盖从1.1版本到1.2版本的更改内容。spring-doc.cadn.net.cn

自定义对象映射器

You can provide your own Jackson ObjectMapper that Pulsar will use when producing and consuming JSON messages. See Custom Object Mapper for more details.spring-doc.cadn.net.cn

默认租户和命名空间

您可以在使用非完全限定的主题URL进行消息的生产和消费时，指定默认租户和/或命名空间。查看默认租户 / 命名空间以获取更多详情。spring-doc.cadn.net.cn

消息容器启动策略

You can now configure the message listener container startup failure policy to stop, continue, or retry. For more details see the corresponding section for one of the supported containers @PulsarListener, @PulsarReader, or @ReactivePulsarListener spring-doc.cadn.net.cn

消息容器工厂自定义器 (Spring Boot)

Spring Boot 引入了一个通用的消息容器工厂自定义器 org.springframework.boot.autoconfigure.pulsar.PulsarContainerFactoryCustomizer<T extends PulsarContainerFactory<?, ?>>，可以用于进一步配置一个或多个为以下监听器注解所支持的自动配置容器工厂：spring-doc.cadn.net.cn

为 0 注册一个或多个 PulsarContainerFactoryCustomizer<ConcurrentPulsarListenerContainerFactory<?>> beans。spring-doc.cadn.net.cn
为 0 注册一个或多个 PulsarContainerFactoryCustomizer<DefaultPulsarReaderContainerFactory<?>> beans。spring-doc.cadn.net.cn
为 0 注册一个或多个 PulsarContainerFactoryCustomizer<DefaultReactivePulsarListenerContainerFactory<?>> beans。spring-doc.cadn.net.cn

弃用

PulsarClient#getPartitionsForTopic(java.lang.String)

版本 3.3.1 的 Pulsar 客户端弃用 getPartitionsForTopic(java.lang.String)，改用 getPartitionsForTopic(java.lang.String, boolean metadataAutoCreationEnabled)。spring-doc.cadn.net.cn

Pulsar主题#构建器

当使用 Spring Boot 时，PulsarTopicBuilder 现在是一个已注册的 bean，其 domain、tenant 和 namespace 配置使用默认值。因此，如果您使用 Spring Boot，可以在需要的地方直接注入 builder。否则，请直接使用其中一个 PulsarTopicBuilder 构造函数。spring-doc.cadn.net.cn

监听器/读取器容器工厂

The PulsarContainerFactory 共用接口被引入，以在监听器和阅读器容器工厂之间建立桥梁。作为这部分内容的一部分，以下API被弃用、复制并重命名：spring-doc.cadn.net.cn

ListenerContainerFactory#createListenerContainer 替换为 ListenerContainerFactory#createRegisteredContainerspring-doc.cadn.net.cn
ReaderContainerFactory#createReaderContainer(E endpoint) 替换为 ReaderContainerFactory#createRegisteredContainerspring-doc.cadn.net.cn
ReaderContainerFactory#createReaderContainer(String… topics) 替换为 ReaderContainerFactory#createContainerspring-doc.cadn.net.cn

ConcurrentPulsarListenerContainerFactoryCustomizer

ConcurrentPulsarListenerContainerFactoryCustomizer 的目的是自定义 Spring Boot 自动配置的消息容器工厂。然而，Spring Boot 引入了一个通用的消息容器工厂自定义器 org.springframework.boot.autoconfigure.pulsar.PulsarContainerFactoryCustomizer<T extends PulsarContainerFactory<?, ?>>，从而不再需要此自定义器。spring-doc.cadn.net.cn

替换所有 ConcurrentPulsarListenerContainerFactoryCustomizer 实例为 org.springframework.boot.autoconfigure.pulsar.PulsarContainerFactoryCustomizer<ConcurrentPulsarListenerContainerFactoryCustomizer<?>>。spring-doc.cadn.net.cn

移除

以下此前已弃用的监听器端点适配器已移除，以便优先使用监听器端点接口中的默认方法：spring-doc.cadn.net.cn

org.springframework.pulsar.config.PulsarListenerEndpointAdapterspring-doc.cadn.net.cn
org.springframework.pulsar.reactive.config.ReactivePulsarListenerEndpointAdapterspring-doc.cadn.net.cn

重大变更

PulsarTopic#<init>

The PulsarTopic 构造函数现在需要一个完全限定的主题名称 (domain://tenant/namespace/name）。如果你调用构造函数，你需要确保传入的主题名称是完全限定的。更好的替代方案是使用 PulsarTopicBuilder，因为它不需要完全限定的名称，并会在指定名称中为缺失的组件添加默认值。spring-doc.cadn.net.cn

PulsarReaderFactory#createReader

The PulsarReaderFactory#createReader API 现在抛出一个未检查的 PulsarException 而不是一个检查的 PulsarClientException。请相应地替换此 API 上的任何 try/catch 块。spring-doc.cadn.net.cn