Update TopicLookupBase.java

[Bug] Fix lookupRequestSemaphore leak when topic not found via http protocol
pengxiangrui127 · Nov 30, 2023 · 0b6804d · 0b6804d
1 parent 5c89188
commit 0b6804d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/TopicLookupBase.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/TopicLookupBase.java
@@ -79,6 +79,7 @@ protected CompletableFuture<LookupData> internalLookupTopicAsync(final TopicName
                 })
                 .thenCompose(exist -> {
                     if (!exist) {
+                        pulsar().getBrokerService().getLookupRequestSemaphore().release();
                         throw new RestException(Response.Status.NOT_FOUND,
                                 String.format("Topic not found %s", topicName.toString()));
                     }