[fix][broker] Invalidate metadata children cache after key deleted (a…

…pache#20363) (cherry picked from commit 64831dc)
datastax · Jul 17, 2023 · ba7f03e · ba7f03e
1 parent 9f39688
commit ba7f03e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java
@@ -206,6 +206,7 @@ public void accept(Notification n) {
 
         if (type == NotificationType.Created || type == NotificationType.Deleted) {
             existsCache.synchronous().invalidate(path);
+            childrenCache.synchronous().invalidate(path);
             String parent = parent(path);
             if (parent != null) {
                 childrenCache.synchronous().invalidate(parent);
@@ -232,6 +233,7 @@ public final CompletableFuture<Void> delete(String path, Optional<Long> expected
         return storeDelete(path, expectedVersion)
                 .thenRun(() -> {
                     existsCache.synchronous().invalidate(path);
+                    childrenCache.synchronous().invalidate(path);
                     String parent = parent(path);
                     if (parent != null) {
                         childrenCache.synchronous().invalidate(parent);