From 7314b33d5e9bcb0f641f4f1733243313ad02aae0 Mon Sep 17 00:00:00 2001
From: Imri Paran <imri.paran@gmail.com>
Date: Mon, 19 May 2025 17:02:23 +0200
Subject: [PATCH] fix: added io.collate to allowed consumer packages (#21278)

---
 .../events/subscription/EventSubscriptionMapper.java         | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/events/subscription/EventSubscriptionMapper.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/events/subscription/EventSubscriptionMapper.java
index e78dfc83b2a..3dbf29b37bd 100644
--- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/events/subscription/EventSubscriptionMapper.java
+++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/events/subscription/EventSubscriptionMapper.java
@@ -42,8 +42,9 @@ public class EventSubscriptionMapper
 
   private String validateConsumerClass(String className) {
     // Validate that the class belongs to our application package
-    if (!className.startsWith("org.openmetadata.")) {
-      throw new BadRequestException("Only classes from org.openmetadata package are allowed");
+    if (!className.startsWith("org.openmetadata.") && !className.contains("io.collate.")) {
+      throw new BadRequestException(
+          "Only classes from org.openmetadata or io.collate packages are allowed: " + className);
     }
 
     try {