From fce358eaa2c154acabcce851aa22dc783c30d5dc Mon Sep 17 00:00:00 2001
From: Mohit Yadav <105265192+mohityadav766@users.noreply.github.com>
Date: Tue, 18 Feb 2025 18:36:58 +0530
Subject: [PATCH] Remove and read alert on sync offset (#19862)

---
 .../service/jdbi3/EventSubscriptionRepository.java             | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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;
   }