You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2021/12/07 04:01:42 UTC
[GitHub] [pulsar] nlu90 opened a new issue #13160: [admin] enhance rest api to help calculate the ending MessageID with a starting MessageID and an offset number
nlu90 opened a new issue #13160:
URL: https://github.com/apache/pulsar/issues/13160
**Is your feature request related to a problem? Please describe.**
Data processing framework sometimes need to limit the # of messages read from one read iteration, and this requires knowing the ending message id. Unlike kafka, pulsar's message id is not linear offset based, so this information is tricky to get on client side.
**Describe the solution you'd like**
Add a new admin rest api or enhance the existing `topics get-message-id` cmd that will help calculate the messageID given an existing messageID and an offset.
`./bin/pulsar-admin topics get-message-id --staringID $STARTING_MESSAGE_ID --count $N`
the command should return an message id that is the $N th message starting from the $STARTING_MESSAGE_ID
And we could reuse some of the logic here:
https://github.com/apache/pulsar/blob/e7b0e3dbc5b6a05e955dc2cad034de0487463150/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java#L3155
**Describe alternatives you've considered**
A clear and concise description of any alternative solutions or features you've considered.
**Additional context**
Add any other context or screenshots about the feature request here.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] github-actions[bot] commented on issue #13160: [admin] enhance rest api to help calculate the ending MessageID with a starting MessageID and an offset number
Posted by GitBox <gi...@apache.org>.
github-actions[bot] commented on issue #13160:
URL: https://github.com/apache/pulsar/issues/13160#issuecomment-1051439928
The issue had no activity for 30 days, mark with Stale label.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] RobertIndie commented on issue #13160: [admin] enhance rest api to help calculate the ending MessageID with a starting MessageID and an offset number
Posted by GitBox <gi...@apache.org>.
RobertIndie commented on issue #13160:
URL: https://github.com/apache/pulsar/issues/13160#issuecomment-987997053
I think I can help with this.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org