[pulsar-broker] fix: use correct configuration for zk-cache expire ti…

…me (#8302)
apache · Oct 19, 2020 · d8f319e · d8f319e
1 parent 52e441f
commit d8f319e
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZooKeeperCache.java b/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZooKeeperCache.java
@@ -108,17 +108,17 @@ public ZooKeeperCache(String cacheName, ZooKeeper zkSession, int zkOperationTime
 
         this.dataCache = Caffeine.newBuilder()
                 .recordStats()
-                .expireAfterWrite(zkOperationTimeoutSeconds, TimeUnit.SECONDS)
+                .expireAfterWrite(cacheExpirySeconds, TimeUnit.SECONDS)
                 .buildAsync((key, executor1) -> null);
 
         this.childrenCache = Caffeine.newBuilder()
                 .recordStats()
-                .expireAfterWrite(zkOperationTimeoutSeconds, TimeUnit.SECONDS)
+                .expireAfterWrite(cacheExpirySeconds, TimeUnit.SECONDS)
                 .buildAsync((key, executor1) -> null);
 
         this.existsCache = Caffeine.newBuilder()
                 .recordStats()
-                .expireAfterWrite(zkOperationTimeoutSeconds, TimeUnit.SECONDS)
+                .expireAfterWrite(cacheExpirySeconds, TimeUnit.SECONDS)
                 .buildAsync((key, executor1) -> null);
 
         CacheMetricsCollector.CAFFEINE.addCache(cacheName + "-data", dataCache);