bianca_unifeye
Databricks MVP

Moving from batch → event-driven / CDC on Databricks usually means adopting streaming + incremental processing across the Bronze → Silver → Gold (Medallion) layers.

Key design factors to capture upfront

  • Event source: Kafka / Event Hubs / Kinesis / Debezium / app events

  • CDC strategy: source-side CDC vs Delta Change Data Feed (CDF)

  • Exactly-once & ordering: idempotent writes, keys, watermarking

  • Schema evolution: schema enforcement vs evolution at Bronze

  • Data quality: quarantine bad records early (expectations)

  • Scalability & recovery: checkpoints, replay, backfills

  • Latency vs cost: micro-batch vs continuous triggers

  • Governance: Unity Catalog, lineage, access controls

Typical Databricks pattern

  • Bronze: Event ingestion using Auto Loader / streaming, raw append

  • Silver: Apply CDC using Delta Live Tables (apply_changes) or Delta CDF

  • Gold: Incremental aggregates / serving tables (streaming or triggered)

Recommended Databricks documentation

This combination gives you event-driven ingestion, scalable CDC, built-in data quality, and recoverability while staying fully aligned with Databricks best practices.

View solution in original post