From 226c554eaf977dd26ecd20c4d6743f811c6cbd0c Mon Sep 17 00:00:00 2001
From: "adel.kalimullin" <a.kalimullin@micord.ru>
Date: Tue, 10 Jun 2025 17:13:25 +0300
Subject: [PATCH] =?UTF-8?q?SUPPORT-9212:=20=D1=84=D0=B8=D0=BA=D1=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ervu_business_metrics/kafka/model/UpsertMessage.java | 9 +++++++++
 .../service/IdmDirectoriesService.java                   | 3 ++-
 2 files changed, 11 insertions(+), 1 deletion(-)

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());