diff --git a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/cache/impl/MetadataCacheImpl.java b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/cache/impl/MetadataCacheImpl.java
index fccbe2ca38a6c..e3c6117a7a1c4 100644
--- a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/cache/impl/MetadataCacheImpl.java
+++ b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/cache/impl/MetadataCacheImpl.java
@@ -255,12 +255,12 @@ public CompletableFuture<List<String>> getChildren(String path) {
     }
 
     @Override
-    public void invalidate(String path) {
+    public synchronized void invalidate(String path) {
         objCache.synchronous().invalidate(path);
     }
 
     @Override
-    public void refresh(String path) {
+    public synchronized void refresh(String path) {
         // Refresh object of path if only it is cached before.
         if (objCache.getIfPresent(path) != null) {
             objCache.synchronous().invalidate(path);
@@ -269,7 +269,7 @@ public void refresh(String path) {
     }
 
     @VisibleForTesting
-    public void invalidateAll() {
+    public synchronized void invalidateAll() {
         objCache.synchronous().invalidateAll();
     }