pulsar-jms icon indicating copy to clipboard operation
pulsar-jms copied to clipboard

Allow direct message replaying by exposing Pulsar API's seek() function

Open yabinmeng opened this issue 3 years ago • 1 comments

When we use Pulsar as the underlying message processing platform, one big benefit is to allow message replaying. This feature is beyond the capability of existing JMS technologies although it is desired in certain use cases.

Since Starlight for JMS API is based on Pulsar's native client API. It is therefore possible to achieve message replay by exposing Pulsar consumer and reader API's cursor seeking capability. For example, by exposing seek(long timestamp), we can actually replay historical messages up to a certain time.

I understand that this is not part of the JMS spec. We could make this as a special bonus feature when we use Pulsar as the underlying messaging platform.

yabinmeng avatar Nov 19 '21 21:11 yabinmeng

Do you have some suggestion for this new API ? Would you add it to the MessageConsumer API ?

eolivelli avatar May 26 '22 13:05 eolivelli