新增功能

自 1.0 以来 1.1 中的新增功能

本节介绍从版本 1.0 到版本 1.1 所做的更改。spring-doc.cadn.net.cn

自动架构支持

如果无法提前知道某个 Pulsar 主题的 schema,你可以使用 AUTO Schemas 向 broker 生成/消费泛型记录。 有关更多详细信息,请参阅使用 AUTO_SCHEMA 生产和使用 AUTO_SCHEMAspring-doc.cadn.net.cn

虽然上述链接侧重于PulsarTemplate@PulsarListener,此功能在ReactivePulsarTemplate,@ReactivePulsarListener@PulsarReader. 每个选项的详细信息可以在本参考指南的相应部分中找到。

通过消息注释的默认主题/架构

您现在可以使用@PulsarMessage以指定在生成/使用该类型的消息时要使用的 default topic 和/或 default schemaspring-doc.cadn.net.cn

删除选中的异常

框架提供的 API 不再抛出 checkedPulsarClientException,而是未选中的PulsarException.spring-doc.cadn.net.cn

如果您之前正在接球或重新抛出PulsarClientException只是为了安抚编译器而不是实际处理异常,你可以简单地删除你的catchthrows第。 如果您实际上是在处理异常,则需要将PulsarClientExceptionPulsarException在 catch 子句中。

测试支持

spring-pulsar-test模块现在可用于帮助测试 Spring for Apache Pulsar 应用程序。 有关更多详细信息,请参阅测试应用程序spring-doc.cadn.net.cn