diff --git a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventSourceManager.java b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventSourceManager.java
index f9304b6ca6..bd299b464a 100644
--- a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventSourceManager.java
+++ b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventSourceManager.java
@@ -234,7 +234,7 @@ public EventSource dynamicallyRegisterEventSource(String name,
     synchronized (this) {
       var actual = eventSources.existing(name, eventSource);
       if (actual != null) {
-        eventSource = actual;
+        eventSource = actual.eventSource();
       } else {
         registerEventSource(name, eventSource);
       }