什么是新内容？

自 1.2 以来 2.0 的新特性

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

Spring 重试替换为核心重试

近期，所有对 Spring Retry 的使用都已替换为由 Spring Framework 引入的更简单的重试机制。spring-doc.cadn.net.cn

这主要是一个在重启消息容器时使用的内部实现细节。这只会影响你，如果你之前通过一个PulsarContainerFactoryCustomizer类型的bean提供了自定义的RetryTemplate。spring-doc.cadn.net.cn

The RetryTemplate 类仍然存在于 Core Retry 中，但包名从 org.springframework.retry.support 更改为 org.springframework.core.retry，并且 API 有轻微的变化。spring-doc.cadn.net.cn

查看提交了解更多详情。spring-doc.cadn.net.cn

移除

previously 废弃的 API

以下此前已弃用的API，在2.0.x版本中被标记为移除，现已被移除：spring-doc.cadn.net.cn

org.springframework.pulsar.config.ConcurrentPulsarListenerContainerFactory#setConcurrencyspring-doc.cadn.net.cn
org.springframework.pulsar.config.ConcurrentPulsarListenerContainerFactoryCustomizerspring-doc.cadn.net.cn
org.springframework.pulsar.config.ListenerContainerFactory#createListenerContainerspring-doc.cadn.net.cn
org.springframework.pulsar.config.ReaderContainerFactory#createReaderContainerspring-doc.cadn.net.cn
org.springframework.pulsar.config.ProducerBuilderConfigurationUtilspring-doc.cadn.net.cn
org.springframework.pulsar.config.PulsarClientProxy#getPartitionsForTopicspring-doc.cadn.net.cn
org.springframework.pulsar.config.PulsarTopic#builderspring-doc.cadn.net.cn
org.springframework.pulsar.config.PulsarTopic#getFullyQualifiedTopicNamespring-doc.cadn.net.cn
org.springframework.pulsar.config.Resolved#getspring-doc.cadn.net.cn
org.springframework.pulsar.test.support.model.UserPojospring-doc.cadn.net.cn
org.springframework.pulsar.test.support.model.UserRecordspring-doc.cadn.net.cn

响应式支持

Reactive 支持已从 Spring Pulsar 2.0.0 中移除 - 长期不再发布 spring-pulsar-reactive 模块。spring-doc.cadn.net.cn

最新更新 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

消息容器启动策略

您现在可以将消息监听容器启动失败策略配置为 stop，continue 或 retry。有关详细信息，请参阅对应的支持容器的相应部分 @PulsarListener 或 @PulsarReader。spring-doc.cadn.net.cn

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

Spring Boot 引入了一个通用的消息容器工厂自定义器 org.springframework.boot.pulsar.autoconfigure.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

弃用

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.pulsar.autoconfigure.PulsarContainerFactoryCustomizer<T extends PulsarContainerFactory<?, ?>>，从而不再需要此自定义器。spring-doc.cadn.net.cn

替换所有 ConcurrentPulsarListenerContainerFactoryCustomizer 实例为 org.springframework.boot.pulsar.autoconfigure.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