Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

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

Open
yabinmeng opened this issue Nov 19, 2021 · 1 comment

Comments

@yabinmeng
Copy link
Contributor

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.

@eolivelli
Copy link
Collaborator

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

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants