diff --git a/backend/src/main/java/ervu_business_metrics/kafka/model/UpsertMessage.java b/backend/src/main/java/ervu_business_metrics/kafka/model/UpsertMessage.java
index a7be5ce..9fb9d6a 100644
--- a/backend/src/main/java/ervu_business_metrics/kafka/model/UpsertMessage.java
+++ b/backend/src/main/java/ervu_business_metrics/kafka/model/UpsertMessage.java
@@ -9,6 +9,7 @@ import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
 @JsonIgnoreProperties(ignoreUnknown = true)
 public class UpsertMessage<T>{
   private T data;
+  private boolean success;
 
   public T getData() {
     return data;
@@ -17,4 +18,12 @@ public class UpsertMessage<T>{
   public void setData(T  data) {
     this.data = data;
   }
+
+  public boolean isSuccess() {
+    return success;
+  }
+
+  public void setSuccess(boolean success) {
+    this.success = success;
+  }
 }
diff --git a/backend/src/main/java/ervu_business_metrics/service/IdmDirectoriesService.java b/backend/src/main/java/ervu_business_metrics/service/IdmDirectoriesService.java
index 240ea83..4890184 100644
--- a/backend/src/main/java/ervu_business_metrics/service/IdmDirectoriesService.java
+++ b/backend/src/main/java/ervu_business_metrics/service/IdmDirectoriesService.java
@@ -81,7 +81,8 @@ public class IdmDirectoriesService {
 
       UpsertMessage<T> message = objectMapper.readValue(kafkaMessage, messageType);
 
-      if (message.getData() != null) {
+      if (Boolean.TRUE.equals(message.isSuccess())
+          && message.getData() != null) {
         DataProcessor<T, ?> processor = (DataProcessor<T, ?>) dataProcessors.get(entityClass);
         if (processor == null) {
           throw new IllegalStateException("No processor found for " + entityClass.getSimpleName());