diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/EventSubscriptionRepository.java b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/EventSubscriptionRepository.java
index a5030f6abe8..52ac95ba0e4 100644
--- a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/EventSubscriptionRepository.java
+++ b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/EventSubscriptionRepository.java
@@ -115,7 +115,7 @@ public class EventSubscriptionRepository extends EntityRepository<EventSubscript
   }
 
   public EventSubscriptionOffset syncEventSubscriptionOffset(String eventSubscriptionName) {
-    EventSubscription eventSubscription = getByName(null, eventSubscriptionName, getFields("id"));
+    EventSubscription eventSubscription = getByName(null, eventSubscriptionName, getFields("*"));
     long latestOffset = daoCollection.changeEventDAO().getLatestOffset();
     long currentTime = System.currentTimeMillis();
     // Upsert Offset
@@ -133,6 +133,7 @@ public class EventSubscriptionRepository extends EntityRepository<EventSubscript
             "eventSubscriptionOffset",
             JsonUtils.pojoToJson(eventSubscriptionOffset));
 
+    EventSubscriptionScheduler.getInstance().updateEventSubscription(eventSubscription);
     return eventSubscriptionOffset;
   }