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 index 34b55a6c5a6dd..7f9b8d1c3583e 100644 --- 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 @@ -113,12 +113,12 @@ public ZooKeeperCache(String cacheName, ZooKeeper zkSession, int zkOperationTime 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);