-
Notifications
You must be signed in to change notification settings - Fork 3.5k
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
Websocket API - Expose ReachedEndOfTopic in Reader/Consumer API #2687
Comments
@sfescape the Reader and Consumer API does have this functionality: reader.hasReachedEndOfTopic() |
In looking at the Websocket API documentation, I don't see anything in the endpoint responses that give me that information. I understand it's available in the other interfaces. |
@sfescape Currently this feature is not available in websocket. you can check this out for the feature parity between clients: https://github.com/apache/pulsar/wiki/Client-Features-Matrix |
Thank you, this feature seems to be "Reader hasMessageAvailable". This project doesn't seem to use JIRA, is there a place I can go look for any roadmap on websocket API features? |
@sfescape we are using github issues for the issue management. the wiki page is for tracking the feature parity. we are currently catching up on c++ and python (we are almost caught up there). however regarding websocket, it is still in the backlog. we put that in low priority since there is no real asks before. we will try to prioritize it since now we are seeing requests. |
Fixes #2687 ### Motivation Expose ReachedEndOfTopic in Reader/Consumer API ### Modifications Add a request of type `isEndOfTopic` to check if consumer/reader has reached end of topic and send response based on result.
nice :-) |
It would be very helpful if there was an ability to test ReachedEndOfTopic. It's not clear to me when you can stop reading if you're only interested in traversing existing messages for a topic.
The text was updated successfully, but these errors were encountered: