新增功能?
1.1 版本相较于 1.0 版本的新增功能
本节介绍从 1.0 版到 1.1 版所做的更改。
自动 Schema 支持
如果事先无法知道 Pulsar 主题的模式,可以使用自动 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 应用程序。有关更多详细信息,请参阅测试应用程序。