新增功能
自 1.0 以来 1.1 中的新增功能
本节介绍从版本 1.0 到版本 1.1 所做的更改。
自动架构支持
如果无法提前知道某个 Pulsar 主题的 schema,你可以使用 AUTO Schemas 向 broker 生成/消费泛型记录。 有关更多详细信息,请参阅使用 AUTO_SCHEMA 生产和使用 AUTO_SCHEMA。
虽然上述链接侧重于PulsarTemplate和@PulsarListener,此功能在ReactivePulsarTemplate,@ReactivePulsarListener和@PulsarReader.
每个选项的详细信息可以在本参考指南的相应部分中找到。 |
通过消息注释的默认主题/架构
您现在可以使用@PulsarMessage以指定在生成/使用该类型的消息时要使用的 default topic 和/或 default schema。
删除选中的异常
框架提供的 API 不再抛出 checkedPulsarClientException,而是未选中的PulsarException.
如果您之前正在接球或重新抛出PulsarClientException只是为了安抚编译器而不是实际处理异常,你可以简单地删除你的catch或throws第。
如果您实际上是在处理异常,则需要将PulsarClientException跟PulsarException在 catch 子句中。 |
测试支持
这spring-pulsar-test模块现在可用于帮助测试 Spring for Apache Pulsar 应用程序。
有关更多详细信息,请参阅测试应用程序。