removed pre-process the Update Indices hook. For current code to trac…

…k events for kibana, we have to go through kafka route
aqden · Feb 19, 2024 · a4c83ea · a4c83ea
1 parent 55848ef
commit a4c83ea
Showing 1 changed file with 0 additions and 8 deletions.
diff --git a/...a-jobs/mae-consumer/src/main/java/com/linkedin/metadata/kafka/hook/UpdateIndicesHook.java b/...a-jobs/mae-consumer/src/main/java/com/linkedin/metadata/kafka/hook/UpdateIndicesHook.java
@@ -41,14 +41,6 @@ public boolean isEnabled() {
 
   @Override
   public void invoke(@Nonnull final MetadataChangeLog event) {
-    if (event.getSystemMetadata() != null) {
-      if (event.getSystemMetadata().getProperties() != null) {
-        if (UI_SOURCE.equals(event.getSystemMetadata().getProperties().get(APP_SOURCE))) {
-          // If coming from the UI, we pre-process the Update Indices hook as a fast path to avoid Kafka lag
-          return;
-        }
-      }
-    }
     _updateIndicesService.handleChangeEvent(event);
   }
 }