operator-framework · csviri · Mar 13, 2026 · Mar 30, 2026 · Apr 29, 2026 · May 4, 2026
diff --git a/bootstrapper-maven-plugin/pom.xml b/bootstrapper-maven-plugin/pom.xml
@@ -22,7 +22,7 @@
   <parent>
     <groupId>io.javaoperatorsdk</groupId>
     <artifactId>java-operator-sdk</artifactId>
-    <version>5.3.4-SNAPSHOT</version>
+    <version>999-SNAPSHOT</version>
   </parent>
 
   <artifactId>bootstrapper</artifactId>

diff --git a/caffeine-bounded-cache-support/pom.xml b/caffeine-bounded-cache-support/pom.xml
@@ -21,7 +21,7 @@
   <parent>
     <groupId>io.javaoperatorsdk</groupId>
     <artifactId>java-operator-sdk</artifactId>
-    <version>5.3.4-SNAPSHOT</version>
+    <version>999-SNAPSHOT</version>
   </parent>
 
   <artifactId>caffeine-bounded-cache-support</artifactId>

diff --git a/micrometer-support/pom.xml b/micrometer-support/pom.xml
@@ -21,7 +21,7 @@
   <parent>
     <groupId>io.javaoperatorsdk</groupId>
     <artifactId>java-operator-sdk</artifactId>
-    <version>5.3.4-SNAPSHOT</version>
+    <version>999-SNAPSHOT</version>
   </parent>
 
   <artifactId>micrometer-support</artifactId>

diff --git a/migration/pom.xml b/migration/pom.xml
@@ -21,7 +21,7 @@
   <parent>
     <groupId>io.javaoperatorsdk</groupId>
     <artifactId>java-operator-sdk</artifactId>
-    <version>5.3.4-SNAPSHOT</version>
+    <version>999-SNAPSHOT</version>
   </parent>
 
   <artifactId>migration</artifactId>

diff --git a/operator-framework-bom/pom.xml b/operator-framework-bom/pom.xml
@@ -21,7 +21,7 @@
 
   <groupId>io.javaoperatorsdk</groupId>
   <artifactId>operator-framework-bom</artifactId>
-  <version>5.3.4-SNAPSHOT</version>
+  <version>999-SNAPSHOT</version>
   <packaging>pom</packaging>
   <name>Operator SDK - Bill of Materials</name>
   <description>Java SDK for implementing Kubernetes operators</description>

diff --git a/operator-framework-core/pom.xml b/operator-framework-core/pom.xml
@@ -21,7 +21,7 @@
   <parent>
     <groupId>io.javaoperatorsdk</groupId>
     <artifactId>java-operator-sdk</artifactId>
-    <version>5.3.4-SNAPSHOT</version>
+    <version>999-SNAPSHOT</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/...in/java/io/javaoperatorsdk/operator/processing/event/source/informer/InformerManager.java b/...in/java/io/javaoperatorsdk/operator/processing/event/source/informer/InformerManager.java
@@ -149,7 +149,6 @@ private InformerWrapper<R> createEventSource(
       ResourceEventHandler<R> eventHandler,
       String namespaceIdentifier) {
     final var informerConfig = configuration.getInformerConfig();
-
     if (informerConfig.getFieldSelector() != null
         && !informerConfig.getFieldSelector().getFields().isEmpty()) {
       for (var f : informerConfig.getFieldSelector().getFields()) {

diff --git a/...ava/io/javaoperatorsdk/operator/processing/event/source/pool/AbstractEventSourcePool.java b/...ava/io/javaoperatorsdk/operator/processing/event/source/pool/AbstractEventSourcePool.java
@@ -0,0 +1,3 @@
+package io.javaoperatorsdk.operator.processing.event.source.pool;
+
+public abstract class AbstractEventSourcePool<C, T> implements EventSourcePool<C, T> {}
diff --git a/...c/main/java/io/javaoperatorsdk/operator/processing/event/source/pool/EventSourcePool.java b/...c/main/java/io/javaoperatorsdk/operator/processing/event/source/pool/EventSourcePool.java
@@ -0,0 +1,8 @@
+package io.javaoperatorsdk.operator.processing.event.source.pool;
+
+public interface EventSourcePool<C, T> {
+
+  T getEventSource(C classifier);
+
+  void removeEventSource(T informerEventSource);
+}
diff --git a/...ain/java/io/javaoperatorsdk/operator/processing/event/source/pool/InformerClassifier.java b/...ain/java/io/javaoperatorsdk/operator/processing/event/source/pool/InformerClassifier.java
@@ -0,0 +1,10 @@
+package io.javaoperatorsdk.operator.processing.event.source.pool;
+
+import io.fabric8.kubernetes.api.model.HasMetadata;
+import io.javaoperatorsdk.operator.api.config.informer.FieldSelector;
+
+public record InformerClassifier(
+    String labelSelector,
+    String namespaceIdentifier,
+    Class<? extends HasMetadata> resourceClass,
+    FieldSelector fieldSelector) {}
diff --git a/.../src/main/java/io/javaoperatorsdk/operator/processing/event/source/pool/InformerPool.java b/.../src/main/java/io/javaoperatorsdk/operator/processing/event/source/pool/InformerPool.java
@@ -0,0 +1,38 @@
+package io.javaoperatorsdk.operator.processing.event.source.pool;
+
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.atomic.AtomicInteger;
+
+import io.fabric8.kubernetes.client.KubernetesClient;
+import io.fabric8.kubernetes.client.informers.SharedIndexInformer;
+
+public class InformerPool
+    extends AbstractEventSourcePool<InformerClassifier, SharedIndexInformer<?>> {
+
+  private final KubernetesClient client;
+
+  private Map<InformerClassifier, SharedIndexInformer<?>> informers = new ConcurrentHashMap<>();
+  private Map<SharedIndexInformer<?>, AtomicInteger> counters = new ConcurrentHashMap<>();
+
+  public InformerPool(KubernetesClient client) {
+    this.client = client;
+  }
+
+  @Override
+  public SharedIndexInformer<?> getEventSource(InformerClassifier classifier) {
+    var actual = informers.get(classifier);
+    if (actual == null) {
+      actual = null; // create Informer
+    }
+    incrementCounter(actual);
+    return null;
+  }
+
+  private synchronized void incrementCounter(SharedIndexInformer<?> actual) {
+    counters.compute(actual, (k, v) -> new AtomicInteger(v == null ? 0 : v.incrementAndGet()));
+  }
+
+  @Override
+  public void removeEventSource(SharedIndexInformer<?> informerEventSource) {}
+}
diff --git a/operator-framework-junit/pom.xml b/operator-framework-junit/pom.xml
@@ -21,7 +21,7 @@
   <parent>
     <groupId>io.javaoperatorsdk</groupId>
     <artifactId>java-operator-sdk</artifactId>
-    <version>5.3.4-SNAPSHOT</version>
+    <version>999-SNAPSHOT</version>
   </parent>
 
   <artifactId>operator-framework-junit</artifactId>

diff --git a/operator-framework/pom.xml b/operator-framework/pom.xml
@@ -21,7 +21,7 @@
   <parent>
     <groupId>io.javaoperatorsdk</groupId>
     <artifactId>java-operator-sdk</artifactId>
-    <version>5.3.4-SNAPSHOT</version>
+    <version>999-SNAPSHOT</version>
   </parent>
 
   <artifactId>operator-framework</artifactId>

diff --git a/pom.xml b/pom.xml
@@ -21,7 +21,7 @@
 
   <groupId>io.javaoperatorsdk</groupId>
   <artifactId>java-operator-sdk</artifactId>
-  <version>5.3.4-SNAPSHOT</version>
+  <version>999-SNAPSHOT</version>
   <packaging>pom</packaging>
   <name>Operator SDK for Java</name>
   <description>Java SDK for implementing Kubernetes operators</description>

diff --git a/sample-operators/controller-namespace-deletion/pom.xml b/sample-operators/controller-namespace-deletion/pom.xml
@@ -22,7 +22,7 @@
   <parent>
     <groupId>io.javaoperatorsdk</groupId>
     <artifactId>sample-operators</artifactId>
-    <version>5.3.4-SNAPSHOT</version>
+    <version>999-SNAPSHOT</version>
   </parent>
 
   <artifactId>sample-controller-namespace-deletion</artifactId>

diff --git a/sample-operators/leader-election/pom.xml b/sample-operators/leader-election/pom.xml
@@ -22,7 +22,7 @@
   <parent>
     <groupId>io.javaoperatorsdk</groupId>
     <artifactId>sample-operators</artifactId>
-    <version>5.3.4-SNAPSHOT</version>
+    <version>999-SNAPSHOT</version>
   </parent>
 
   <artifactId>sample-leader-election</artifactId>

diff --git a/sample-operators/metrics-processing/pom.xml b/sample-operators/metrics-processing/pom.xml
@@ -22,7 +22,7 @@
   <parent>
     <groupId>io.javaoperatorsdk</groupId>
     <artifactId>sample-operators</artifactId>
-    <version>5.3.4-SNAPSHOT</version>
+    <version>999-SNAPSHOT</version>
   </parent>
 
   <artifactId>sample-metrics-processing</artifactId>
@@ -101,11 +101,6 @@
           <to>
             <image>metrics-processing-operator</image>
           </to>
-          <container>
-            <jvmFlags>
-              <jvmFlag>-Dlog4j.configurationFile=/config/log4j2.xml</jvmFlag>
-            </jvmFlags>
-          </container>
         </configuration>
       </plugin>
       <plugin>

diff --git a/sample-operators/mysql-schema/pom.xml b/sample-operators/mysql-schema/pom.xml
@@ -22,7 +22,7 @@
   <parent>
     <groupId>io.javaoperatorsdk</groupId>
     <artifactId>sample-operators</artifactId>
-    <version>5.3.4-SNAPSHOT</version>
+    <version>999-SNAPSHOT</version>
   </parent>
 
   <artifactId>sample-mysql-schema-operator</artifactId>

diff --git a/sample-operators/pom.xml b/sample-operators/pom.xml
@@ -22,7 +22,7 @@
   <parent>
     <groupId>io.javaoperatorsdk</groupId>
     <artifactId>java-operator-sdk</artifactId>
-    <version>5.3.4-SNAPSHOT</version>
+    <version>999-SNAPSHOT</version>
   </parent>
 
   <artifactId>sample-operators</artifactId>

diff --git a/sample-operators/tomcat-operator/pom.xml b/sample-operators/tomcat-operator/pom.xml
@@ -22,7 +22,7 @@
   <parent>
     <groupId>io.javaoperatorsdk</groupId>
     <artifactId>sample-operators</artifactId>
-    <version>5.3.4-SNAPSHOT</version>
+    <version>999-SNAPSHOT</version>
   </parent>
 
   <artifactId>sample-tomcat-operator</artifactId>

diff --git a/sample-operators/webpage/pom.xml b/sample-operators/webpage/pom.xml
@@ -22,7 +22,7 @@
   <parent>
     <groupId>io.javaoperatorsdk</groupId>
     <artifactId>sample-operators</artifactId>
-    <version>5.3.4-SNAPSHOT</version>
+    <version>999-SNAPSHOT</version>
   </parent>
 
   <artifactId>sample-webpage-operator</artifactId>

diff --git a/test-index-processor/pom.xml b/test-index-processor/pom.xml
@@ -22,7 +22,7 @@
   <parent>
     <groupId>io.javaoperatorsdk</groupId>
     <artifactId>java-operator-sdk</artifactId>
-    <version>5.3.4-SNAPSHOT</version>
+    <version>999-SNAPSHOT</version>
   </parent>
 
   <artifactId>test-index-processor</artifactId>
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,3 @@
		package io.javaoperatorsdk.operator.processing.event.source.pool;

		public abstract class AbstractEventSourcePool<C, T> implements EventSourcePool<C, T> {}