Skip to content

Commit 1f7a79f

Browse files
danpihoubonan
andauthored
[fix][admin] Fix exception thrown in getMessageId method (#23784)
Co-authored-by: houbonan <[email protected]>
1 parent f199e88 commit 1f7a79f

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2776,6 +2776,7 @@ public void readEntryFailed(ManagedLedgerException exception,
27762776
if (exception instanceof ManagedLedgerException.LedgerNotExistException) {
27772777
results.completeExceptionally(
27782778
new RestException(Status.NOT_FOUND, "Message id not found"));
2779+
return;
27792780
}
27802781
results.completeExceptionally(new RestException(exception));
27812782
}

0 commit comments

Comments
 (0)