This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 1f7a79f4c24 [fix][admin] Fix exception thrown in getMessageId method
(#23784)
1f7a79f4c24 is described below
commit 1f7a79f4c240c8075c217ac417dffa5bc72a4d5f
Author: danpi <[email protected]>
AuthorDate: Sat Jan 4 02:04:24 2025 +0800
[fix][admin] Fix exception thrown in getMessageId method (#23784)
Co-authored-by: houbonan <[email protected]>
---
.../java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
index 4b9fea05cd8..eed667d4990 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
@@ -2776,6 +2776,7 @@ public class PersistentTopicsBase extends AdminResource {
if (exception instanceof
ManagedLedgerException.LedgerNotExistException) {
results.completeExceptionally(
new RestException(Status.NOT_FOUND,
"Message id not found"));
+ return;
}
results.completeExceptionally(new
RestException(exception));
}