新增功能?

1.1 相比 1.0 的新特性

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

自动 Schema 支持

如果无法提前知道 Pulsar 主题的 Schema,可以使用 AUTO Schema 向代理生产/消费泛型记录。有关更多详细信息,请参阅 使用 AUTO_SCHEMA 生产使用 AUTO_SCHEMA 消费

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

通过消息注解指定默认主题/Schema

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

移除受检异常

框架提供的 API 不再抛出受检的 PulsarClientException,而是抛出非受检的 PulsarException

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

测试支持

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