¿Escalabilidad de los Oyentes Agrupados en Infinispan para Caché con muchas Claves?

Cuando uso una caché incrustada en Infinispan, busco tener un oyente con filtrado en clúster que sea notificado cada vez que una clave específica se actualiza. Mi problema es que el tiempo que le lleva a la caché verificar qué oyentes deben ser notificados cuando se actualiza un valor es una operación O(n), sin ganancias de rendimiento con más nodos en mi clúster. Esto significa que no puedo escalar mi clúster para manejar grandes cantidades de claves.

Esto probablemente se debe al siguiente fragmento de código en CacheNotifierImpl que recorre todos los oyentes:

   private CompletionStage<Void> doNotifyModified(K key, V value, Metadata metadata, V previousValue,
       Metadata previousMetadata, boolean pre, InvocationContext ctx, FlagAffectedCommand command) {
      if (clusteringDependentLogic.running().commitType(command, ctx, extractSegment(command, key), false).isLocal()
          && (command == null || !command.hasAnyFlag(FlagBitSets.PUT_FOR_STATE_TRANSFER))) {
         EventImpl<K, V> e = EventImpl.createEvent(cache.wired(), CACHE_ENTRY_MODIFIED);
         boolean isLocalNodePrimaryOwner = isLocalNodePrimaryOwner(key);
         Object batchIdentifier = ctx.isInTxScope() ? null : Thread.currentThread();
         try {
            AggregateCompletionStage<Void> aggregateCompletionStage = null;
            for (CacheEntryListenerInvocation<K, V> listener : cacheEntryModifiedListeners) {
               // Need a wrapper per invocation since converter could modify the entry in it
               configureEvent(listener, e, key, value, metadata, pre, ctx, command, previousValue, previousMetadata);
               aggregateCompletionStage = composeStageIfNeeded(aggregateCompletionStage,
                  listener.invoke(new EventWrapper<>(key, e), isLocalNodePrimaryOwner));

donde la función listener.invoke verifica el filtro de cada oyente para ver si la función debe invocarse o no. Esto significa que cada nodo siempre tendrá que iterar a través de cada oyente en cada evento, solo para descubrir que casi todos los oyentes no hacen nada.

¿Existe alguna forma sin O(n) de agregar un oyente en todo el clúster donde la biblioteca principal identifique que el oyente solo debe activarse para una clave específica?

Este comportamiento se ha encontrado al utilizar la versión 13.0.0 de la biblioteca infinispan-core.