新增功能?

1.1 版本相较于 1.0 版本的新增功能

本节介绍从 1.0 版到 1.1 版所做的更改。

自动 Schema 支持

如果事先无法知道 Pulsar 主题的模式,可以使用自动 Schema 将泛型记录生产/消费到/从代理中。有关更多详细信息,请参阅使用 AUTO_SCHEMA 生产使用 AUTO_SCHEMA 消费

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

通过消息注释指定默认主题/模式

您现在可以使用@PulsarMessage标记消息类,以指定默认主题和/或默认模式,以用于生产/消费该类型的消息。

移除已检查异常

框架提供的 API 不再抛出已检查的PulsarClientException,而是抛出未检查的PulsarException

如果您之前捕获或重新抛出PulsarClientException只是为了满足编译器的要求,并且实际上没有处理该异常,则可以简单地删除您的catchthrows子句。如果您确实正在处理该异常,则需要在您的 catch 子句中将PulsarClientException替换为PulsarException

测试支持

spring-pulsar-test模块现已可用,可帮助您测试 Spring for Apache Pulsar 应用程序。有关更多详细信息,请参阅测试应用程序