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 index 288e14c10392e..118d46bd53d89 100644 --- 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 @@ -218,9 +218,9 @@ public static CompletableFuture lookupTopicAsync(PulsarService pulsarSe }); // Initiate lookup once validation completes - validationFuture.thenAccept(validaitonFailureResponse -> { - if (validaitonFailureResponse != null) { - lookupfuture.complete(validaitonFailureResponse); + validationFuture.thenAccept(validationFailureResponse -> { + if (validationFailureResponse != null) { + lookupfuture.complete(validationFailureResponse); } else { pulsarService.getNamespaceService().getBrokerServiceUrlAsync(topicName, authoritative) .thenAccept(lookupResult -> {