What’s new?

What’s New in 1.1 Since 1.0

This section covers the changes made from version 1.0 to version 1.1.

Auto Schema support

If there is no chance to know the schema of a Pulsar topic in advance, you can use AUTO Schemas to produce/consume generic records to/from brokers. See Producing with AUTO_SCHEMA and Consuming with AUTO_SCHEMA for more details.

While the above links focus on PulsarTemplate and @PulsarListener, this feature is also supported in ReactivePulsarTemplate, @ReactivePulsarListener, and @PulsarReader. Details for each can be found in their respective section of this reference guide.

Default topic/schema via message annotation

You can now mark a message class with @PulsarMessage to specify the default topic and/or default schema to use when producing/consuming messages of that type.

Remove checked exceptions

The APIs provided by the framework no longer throw the checked PulsarClientException, but rather the unchecked PulsarException.

If you were previously catching or rethrowing PulsarClientException just to appease the compiler and were not actually handling the exception, you can simply remove your catch or throws clause. If you were actually handling the exception then you will need to replace PulsarClientException with PulsarException in your catch clause.

Testing support

The spring-pulsar-test module is now available to help test your Spring for Apache Pulsar applications. See Testing Applications for more details.