新增功能?
1.1 相比 1.0 的新特性
本节介绍了从 1.0 版本到 1.1 版本的更改。
自动 Schema 支持
如果无法提前知道 Pulsar 主题的 Schema,可以使用 AUTO Schema 向代理生产/消费泛型记录。有关更多详细信息,请参阅 使用 AUTO_SCHEMA 生产 和 使用 AUTO_SCHEMA 消费。
虽然上面的链接重点介绍了 PulsarTemplate 和 @PulsarListener ,但此功能也受 ReactivePulsarTemplate 、@ReactivePulsarListener 和 @PulsarReader 支持。每个功能的详细信息可以在本参考指南的相应部分找到。
|
移除受检异常
框架提供的 API 不再抛出受检的 PulsarClientException
,而是抛出非受检的 PulsarException
。
如果您之前只是为了满足编译器而捕获或重新抛出 PulsarClientException ,并且实际上没有处理该异常,则可以简单地删除您的 catch 或 throws 子句。如果您实际上正在处理该异常,那么您需要在您的 catch 子句中将 PulsarClientException 替换为 PulsarException 。
|
测试支持
现在可以使用 spring-pulsar-test
模块来帮助测试您的 Spring for Apache Pulsar 应用程序。有关更多详细信息,请参见 测试应用程序。