diff --git a/services/apps/snowflake_connectors/src/integrations/cvent/event-registrations/buildSourceQuery.ts b/services/apps/snowflake_connectors/src/integrations/cvent/event-registrations/buildSourceQuery.ts
index ebe786c2a8..201c30a27b 100644
--- a/services/apps/snowflake_connectors/src/integrations/cvent/event-registrations/buildSourceQuery.ts
+++ b/services/apps/snowflake_connectors/src/integrations/cvent/event-registrations/buildSourceQuery.ts
@@ -24,7 +24,7 @@ const CDP_MATCHED_SEGMENTS = `
     SELECT DISTINCT
       s.SOURCE_ID AS sourceId,
       s.slug
-    FROM ANALYTICS.SILVER_DIM._CROWD_DEV_SEGMENTS_UNION s
+    FROM ANALYTICS.BRONZE_KAFKA_CROWD_DEV.SEGMENTS s
     WHERE s.PARENT_SLUG IS NOT NULL
       AND s.GRANDPARENTS_SLUG IS NOT NULL
       AND s.SOURCE_ID IS NOT NULL
@@ -91,7 +91,7 @@ export const buildSourceQuery = (sinceTimestamp?: string): string => {
     SELECT DISTINCT
       s.SOURCE_ID AS sourceId,
       s.slug
-    FROM ANALYTICS.SILVER_DIM._CROWD_DEV_SEGMENTS_UNION s
+    FROM ANALYTICS.BRONZE_KAFKA_CROWD_DEV.SEGMENTS s
     WHERE s.CREATED_TS >= '${sinceTimestamp}'
       AND s.PARENT_SLUG IS NOT NULL
       AND s.GRANDPARENTS_SLUG IS NOT NULL
diff --git a/services/apps/snowflake_connectors/src/integrations/tnc/certificates/buildSourceQuery.ts b/services/apps/snowflake_connectors/src/integrations/tnc/certificates/buildSourceQuery.ts
index ffb79daf7e..4fa86795f7 100644
--- a/services/apps/snowflake_connectors/src/integrations/tnc/certificates/buildSourceQuery.ts
+++ b/services/apps/snowflake_connectors/src/integrations/tnc/certificates/buildSourceQuery.ts
@@ -2,7 +2,7 @@ import { IS_PROD_ENV } from '@crowd/common'
 
 // Main: analytics.silver_fact.certificates (certificate data)
 // Joins:
-// - analytics.silver_dim._crowd_dev_segments_union (segment resolution)
+// - ANALYTICS.BRONZE_KAFKA_CROWD_DEV.SEGMENTS (segment resolution)
 // - analytics.bronze_fivetran_salesforce.bronze_salesforce_merged_user (LFID)
 // - analytics.silver_dim.users (LFID fallback)
 // - analytics.bronze_fivetran_salesforce.accounts + analytics.bronze_fivetran_salesforce_b2b.accounts (org data)
@@ -12,7 +12,7 @@ const CDP_MATCHED_SEGMENTS = `
     SELECT DISTINCT
       s.SOURCE_ID AS sourceId,
       s.slug
-    FROM ANALYTICS.SILVER_DIM._CROWD_DEV_SEGMENTS_UNION s
+    FROM ANALYTICS.BRONZE_KAFKA_CROWD_DEV.SEGMENTS s
     WHERE s.PARENT_SLUG IS NOT NULL
       AND s.GRANDPARENTS_SLUG IS NOT NULL
       AND s.SOURCE_ID IS NOT NULL
@@ -79,7 +79,7 @@ export const buildSourceQuery = (sinceTimestamp?: string): string => {
     SELECT DISTINCT
       s.SOURCE_ID AS sourceId,
       s.slug
-    FROM ANALYTICS.SILVER_DIM._CROWD_DEV_SEGMENTS_UNION s
+    FROM ANALYTICS.BRONZE_KAFKA_CROWD_DEV.SEGMENTS s
     WHERE s.CREATED_TS >= '${sinceTimestamp}'
       AND s.PARENT_SLUG IS NOT NULL
       AND s.GRANDPARENTS_SLUG IS NOT NULL
diff --git a/services/apps/snowflake_connectors/src/integrations/tnc/courses/buildSourceQuery.ts b/services/apps/snowflake_connectors/src/integrations/tnc/courses/buildSourceQuery.ts
index 5543716ed6..2d74aa709f 100644
--- a/services/apps/snowflake_connectors/src/integrations/tnc/courses/buildSourceQuery.ts
+++ b/services/apps/snowflake_connectors/src/integrations/tnc/courses/buildSourceQuery.ts
@@ -5,7 +5,7 @@ import { IS_PROD_ENV } from '@crowd/common'
 // - analytics.bronze_census_ti.users (user resolution via internal_ti_user_id)
 // - analytics.bronze_census_ti.courses (course metadata)
 // - analytics.silver_fact.enrollments (segment + org resolution via email + course_id)
-// - analytics.silver_dim._crowd_dev_segments_union (segment resolution)
+// - ANALYTICS.BRONZE_KAFKA_CROWD_DEV.SEGMENTS (segment resolution)
 // - analytics.bronze_fivetran_salesforce.accounts + analytics.bronze_fivetran_salesforce_b2b.accounts (org data)
 
 const CDP_MATCHED_SEGMENTS = `
@@ -13,7 +13,7 @@ const CDP_MATCHED_SEGMENTS = `
     SELECT DISTINCT
       s.SOURCE_ID AS sourceId,
       s.slug
-    FROM ANALYTICS.SILVER_DIM._CROWD_DEV_SEGMENTS_UNION s
+    FROM ANALYTICS.BRONZE_KAFKA_CROWD_DEV.SEGMENTS s
     WHERE s.PARENT_SLUG IS NOT NULL
       AND s.GRANDPARENTS_SLUG IS NOT NULL
       AND s.SOURCE_ID IS NOT NULL
@@ -104,7 +104,7 @@ export const buildSourceQuery = (sinceTimestamp?: string): string => {
     SELECT DISTINCT
       s.SOURCE_ID AS sourceId,
       s.slug
-    FROM ANALYTICS.SILVER_DIM._CROWD_DEV_SEGMENTS_UNION s
+    FROM ANALYTICS.BRONZE_KAFKA_CROWD_DEV.SEGMENTS s
     WHERE s.CREATED_TS >= '${sinceTimestamp}'
       AND s.PARENT_SLUG IS NOT NULL
       AND s.GRANDPARENTS_SLUG IS NOT NULL
diff --git a/services/apps/snowflake_connectors/src/integrations/tnc/enrollments/buildSourceQuery.ts b/services/apps/snowflake_connectors/src/integrations/tnc/enrollments/buildSourceQuery.ts
index 82d1be636a..42328a3c9a 100644
--- a/services/apps/snowflake_connectors/src/integrations/tnc/enrollments/buildSourceQuery.ts
+++ b/services/apps/snowflake_connectors/src/integrations/tnc/enrollments/buildSourceQuery.ts
@@ -2,7 +2,7 @@ import { IS_PROD_ENV } from '@crowd/common'
 
 // Main: analytics.silver_fact.enrollments (enrollment data)
 // Joins:
-// - analytics.silver_dim._crowd_dev_segments_union (segment resolution)
+// - ANALYTICS.BRONZE_KAFKA_CROWD_DEV.SEGMENTS (segment resolution)
 // - analytics.bronze_fivetran_salesforce.bronze_salesforce_merged_user (LFID)
 // - analytics.silver_dim.users (LFID fallback)
 // - analytics.bronze_fivetran_salesforce.accounts + analytics.bronze_fivetran_salesforce_b2b.accounts (org data)
@@ -13,7 +13,7 @@ const CDP_MATCHED_SEGMENTS = `
     SELECT DISTINCT
       s.SOURCE_ID AS sourceId,
       s.slug
-    FROM ANALYTICS.SILVER_DIM._CROWD_DEV_SEGMENTS_UNION s
+    FROM ANALYTICS.BRONZE_KAFKA_CROWD_DEV.SEGMENTS s
     WHERE s.PARENT_SLUG IS NOT NULL
       AND s.GRANDPARENTS_SLUG IS NOT NULL
       AND s.SOURCE_ID IS NOT NULL
@@ -104,7 +104,7 @@ export const buildSourceQuery = (sinceTimestamp?: string): string => {
     SELECT DISTINCT
       s.SOURCE_ID AS sourceId,
       s.slug
-    FROM ANALYTICS.SILVER_DIM._CROWD_DEV_SEGMENTS_UNION s
+    FROM ANALYTICS.BRONZE_KAFKA_CROWD_DEV.SEGMENTS s
     WHERE s.CREATED_TS >= '${sinceTimestamp}'
       AND s.PARENT_SLUG IS NOT NULL
       AND s.GRANDPARENTS_SLUG IS NOT NULL