自 1.0 以来 1.1 中的新增功能
本节介绍从版本 1.0 到版本 1.1 所做的更改。
自动架构支持
如果没有机会提前知道 Pulsar 主题的模式,您可以使用 AUTO 模式来生成/使用与代理之间的通用记录。 有关详细信息,请参阅使用AUTO_SCHEMA生产和使用AUTO_SCHEMA消费。
虽然上述链接侧重于 和 ,但 、 和 也支持此功能。
每个的详细信息都可以在本参考指南的相应部分中找到。PulsarTemplate @PulsarListener ReactivePulsarTemplate @ReactivePulsarListener @PulsarReader |
删除选中的异常
框架提供的 API 不再抛出 checked 的 ,而是抛出未选中的 。PulsarClientException
PulsarException
如果您之前只是为了安抚编译器而捕获或重新抛出,并且实际上并没有处理异常,则可以简单地删除 or 子句。
如果您实际处理了异常,则需要在 catch 子句中替换为 。PulsarClientException catch throws PulsarClientException PulsarException |
测试支持
该模块现在可用于帮助测试 Spring for Apache Pulsar 应用程序。
有关更多详细信息,请参阅测试应用程序。spring-pulsar-test
虽然上述链接侧重于 和 ,但 、 和 也支持此功能。
每个的详细信息都可以在本参考指南的相应部分中找到。PulsarTemplate @PulsarListener ReactivePulsarTemplate @ReactivePulsarListener @PulsarReader |
如果您之前只是为了安抚编译器而捕获或重新抛出,并且实际上并没有处理异常,则可以简单地删除 or 子句。
如果您实际处理了异常,则需要在 catch 子句中替换为 。PulsarClientException catch throws PulsarClientException PulsarException |