in pulsar-client-reactive-producer-cache-caffeine-shaded/src/main/java/org/apache/pulsar/reactive/client/producercache/CaffeineShadedProducerCacheProvider.java [57:68]
public CaffeineShadedProducerCacheProvider(Duration cacheExpireAfterAccess, Duration cacheExpireAfterWrite,
Long cacheMaximumSize, Integer cacheInitialCapacity) {
this.cache = Caffeine.newBuilder()
.expireAfterAccess(cacheExpireAfterAccess)
.expireAfterWrite(cacheExpireAfterWrite)
.maximumSize(cacheMaximumSize)
.initialCapacity(cacheInitialCapacity)
.scheduler(Scheduler.systemScheduler())
.executor(Schedulers.boundedElastic()::schedule)
.removalListener(this::onRemoval)
.buildAsync();
}