Pulsar Reader Support

[rfecher]

I'd like to use the topic retention policy along with a "Reader" client (https://pulsar.apache.org/docs/2.10.x/concepts-clients/#reader-interface) to be able to retrieve all retained messages on initialization of the consumer service, even those that have been acknowledged. It doesn't appear that there is any means to do this in the current spring-pulsar client interfaces?

[onobc]

Hi @rfecher ,

There is currently no support for the regular (imperative client) reader yet. We will try to get to this soon though.

However, there is a Reactive reader that is auto-configured (see https://docs.spring.io/spring-pulsar/docs/current-SNAPSHOT/reference/html/#reactive-pulsar-reader).

[rfecher]

thanks for the quick response @onobc!

[onobc]

Closing via

• Pulsar Reader Auto-Configuration (imperative) #328
• 8dd39fd

[onobc]

@rfecher first wave of the imperative support has been added w/:

• auto-configured PulsarReaderFactory
• config props for the reader factory (spring.pulsar.reader.*)

Docs will be here shortly https://docs.spring.io/spring-pulsar/docs/current-SNAPSHOT/reference/html/#pulsar-reader
https://docs.spring.io/spring-pulsar/docs/current-SNAPSHOT/reference/html/#reactive-pulsar-reader

I believe we are planning on adding a @PulsarReader as well. Stay tuned. But you can grab a snapshot now and give it spin.

P.S. If you are enjoying using the framework so far, please click the star button at the top-right if you don't mind :)