Cover more logical branches: topic future has exceptionally complete

apache · Sep 14, 2022 · 33e4f11 · 33e4f11
1 parent 235d13c
commit 33e4f11
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
@@ -2029,7 +2029,9 @@ public CompletableFuture<Void> removeTopicFromCache(String topicNameString, Topi
                 // Do remove.
                 return removeTopicFutureFromCache(topicNameString, createTopicFuture);
             }
-        });
+            // If the future in cache has exception complete,
+            // the topic instance in the cache is not the same with the topic.
+        }).exceptionally(ex -> null);
     }
 
     private CompletableFuture<Void> removeTopicFutureFromCache(String topic,