diff --git a/apps/onboarding-cdc/src/main/java/it/pagopa/selfcare/onboarding/event/entity/AggregateInstitution.java b/apps/onboarding-cdc/src/main/java/it/pagopa/selfcare/onboarding/event/entity/AggregateInstitution.java
new file mode 100644
index 000000000..18b6949d1
--- /dev/null
+++ b/apps/onboarding-cdc/src/main/java/it/pagopa/selfcare/onboarding/event/entity/AggregateInstitution.java
@@ -0,0 +1,23 @@
+package it.pagopa.selfcare.onboarding.event.entity;
+
+import it.pagopa.selfcare.onboarding.common.Origin;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class AggregateInstitution {
+
+    private String taxCode;
+    private String description;
+    private String subunitCode;
+    private String subunitType;
+    private List<GeographicTaxonomy> geographicTaxonomies;
+    private String address;
+    private String zipCode;
+    private String originId;
+    private Origin origin;
+    private String vatNumber;
+    private List<User> users;
+
+}
diff --git a/apps/onboarding-cdc/src/main/java/it/pagopa/selfcare/onboarding/event/entity/Onboarding.java b/apps/onboarding-cdc/src/main/java/it/pagopa/selfcare/onboarding/event/entity/Onboarding.java
index f480e5b38..b8690047d 100644
--- a/apps/onboarding-cdc/src/main/java/it/pagopa/selfcare/onboarding/event/entity/Onboarding.java
+++ b/apps/onboarding-cdc/src/main/java/it/pagopa/selfcare/onboarding/event/entity/Onboarding.java
@@ -27,6 +27,7 @@ public class Onboarding extends ReactivePanacheMongoEntityBase {
     private List<String> testEnvProductIds;
     private WorkflowType workflowType;
     private Institution institution;
+    private List<AggregateInstitution> aggregates;
     private List<User> users;
     private String pricingPlan;
     private Billing billing;
@@ -40,4 +41,5 @@ public class Onboarding extends ReactivePanacheMongoEntityBase {
     private String userRequestUid;
     private AdditionalInformations additionalInformations;
     private String reasonForReject;
+    private Boolean isAggregator;
 }