自 1.0 以来 1.1 中的新增功能

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

自动架构支持

如果没有机会提前知道 Pulsar 主题的模式,您可以使用 AUTO 模式来生成/使用与代理之间的通用记录。 有关详细信息,请参阅使用AUTO_SCHEMA生产使用AUTO_SCHEMA消费

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

通过消息注释的默认主题/架构

现在,您可以标记消息类,以指定在生成/使用该类型的消息时要使用的默认主题和/或默认架构@PulsarMessage

删除选中的异常

框架提供的 API 不再抛出 checked 的 ,而是抛出未选中的 。PulsarClientExceptionPulsarException

如果您之前只是为了安抚编译器而捕获或重新抛出,并且实际上并没有处理异常,则可以简单地删除 or 子句。 如果您实际处理了异常,则需要在 catch 子句中替换为 。PulsarClientExceptioncatchthrowsPulsarClientExceptionPulsarException

测试支持

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

虽然上述链接侧重于 和 ,但 、 和 也支持此功能。 每个的详细信息都可以在本参考指南的相应部分中找到。PulsarTemplate@PulsarListenerReactivePulsarTemplate@ReactivePulsarListener@PulsarReader
如果您之前只是为了安抚编译器而捕获或重新抛出,并且实际上并没有处理异常,则可以简单地删除 or 子句。 如果您实际处理了异常,则需要在 catch 子句中替换为 。PulsarClientExceptioncatchthrowsPulsarClientExceptionPulsarException