新增功能
自 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 应用程序。
有关更多详细信息,请参阅测试应用程序。