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));
                         }

Reply via email to