-
Notifications
You must be signed in to change notification settings - Fork 3.6k
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
[Pulsar admin] admin command 'get-message-by-id' can get message by messageId regardless of topic name #11814
Comments
which version do you use? |
2.8.0 |
maybe what we need is to clear the description. because in get-message-by-id , you know ledgerId and entryId, what topic belongs of the message is very clear. |
topic is useless in this command, Maybe we should remove it. |
Topic is useful for lookup, and can redirect to the owner broker for finding the managedLedger. But even if we get the wrong managedLedger, we can use the managedLedger to get the message. Maybe we can add createIfMissing in the method 'getLedgerHandle'. |
Does messages from different topics can put into same ledger? |
No。 |
Fix #11814 , if we use another topic to find the message, it will return the message, but we may contaminate the ledgers cache in the topic. **changes** Add check in the method 'internalGetMessageById' in PersistentTopicsBase, if the ledgerId not belong to this topic, throw a exception.
Fix apache#11814 , if we use another topic to find the message, it will return the message, but we may contaminate the ledgers cache in the topic. **changes** Add check in the method 'internalGetMessageById' in PersistentTopicsBase, if the ledgerId not belong to this topic, throw a exception. (cherry picked from commit 9bfb3db)
Fix apache#11814 , if we use another topic to find the message, it will return the message, but we may contaminate the ledgers cache in the topic. **changes** Add check in the method 'internalGetMessageById' in PersistentTopicsBase, if the ledgerId not belong to this topic, throw a exception. (cherry picked from commit 9bfb3db)
Fix #11814 , if we use another topic to find the message, it will return the message, but we may contaminate the ledgers cache in the topic. **changes** Add check in the method 'internalGetMessageById' in PersistentTopicsBase, if the ledgerId not belong to this topic, throw a exception. (cherry picked from commit 9bfb3db)
OK. |
Fix apache#11814 , if we use another topic to find the message, it will return the message, but we may contaminate the ledgers cache in the topic. **changes** Add check in the method 'internalGetMessageById' in PersistentTopicsBase, if the ledgerId not belong to this topic, throw a exception.
The text was updated successfully, but these errors were encountered: