fix(mae-consumer): fix UpdateIndicesHook ignoring events with forceIn…

…dexing property set to true
datahub-project · May 24, 2024 · a58f742 · a58f742
1 parent 47ba6d9
commit a58f742
Showing 1 changed file with 2 additions and 1 deletion.
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
@@ -60,7 +60,8 @@ public UpdateIndicesHook init(@javax.annotation.Nonnull OperationContext systemO
   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 (!Boolean.parseBoolean(event.getSystemMetadata().getProperties().get(FORCE_INDEXING_KEY))
+            && UI_SOURCE.equals(event.getSystemMetadata().getProperties().get(APP_SOURCE))
             && !reprocessUIEvents) {
           // If coming from the UI, we pre-process the Update Indices hook as a fast path to avoid
           // Kafka lag