--- title: Push-based CDC into Unity Catalog with Zerobus Ingest... description: Debezium Server can stream change data capture events straight into Unity Catalog Delta tables via Databricks Zerobus Ingest, skipping a traditional Kafka... canonical: https://daily.dev/posts/push-based-cdc-into-unity-catalog-with-zerobus-ingest-and-debezium-zjvwx1xrw twitter:card: summary_large_image twitter:site: @dailydotdev og:type: website og:site_name: daily.dev og:title: Push-based CDC into Unity Catalog with Zerobus Ingest and Debezium | daily.dev og:description: Debezium Server can stream change data capture events straight into Unity Catalog Delta tables via Databricks Zerobus Ingest, skipping a traditional Kafka... og:url: https://daily.dev/posts/push-based-cdc-into-unity-catalog-with-zerobus-ingest-and-debezium-zjvwx1xrw og:image: https://api.daily.dev/og/posts/zjvwx1xRW.png og:image:alt: Push-based CDC into Unity Catalog with Zerobus Ingest and Debezium og:image:width: 1200 og:image:height: 630 og:locale: en --- > ## Documentation Index > Fetch the complete documentation index at: https://daily.dev/llms.txt > Use this file to discover all available pages before exploring further. # Push-based CDC into Unity Catalog with Zerobus Ingest and Debezium **[databricks](https://daily.dev/sources/databricks)** · 9 min read · 0 upvotes · 0 comments ## Summary Debezium Server can stream change data capture events straight into Unity Catalog Delta tables via Databricks Zerobus Ingest, skipping a traditional Kafka cluster. Databricks built the typed Zerobus Ingest sink, and NVIDIA contributed 'envelope mode', which lands the full change event in a fixed nine-column table with an idempotency key and durable acknowledgment before source offsets advance. The Zerobus sink is shipped in Debezium Server 3.7. Delivery is at-least-once, so duplicates get deduplicated downstream using that key. Teams then use AUTO CDC, sequenced by source LSN, to build a current-state Type-1 table from the raw feed. ## Full article daily.dev links to this article rather than hosting it. Read it at the original source: ## Questions this post answers ### How can I stream PostgreSQL CDC changes into Databricks without running Kafka? Debezium Server can send change events directly to Databricks Zerobus Ingest, which writes them into Unity Catalog governed Delta tables without any message broker. The open-source Debezium Server Zerobus sink, built by NVIDIA and Databricks, ships in Debezium Server 3.7 and eliminates the two-hop Kafka plus ingestion-job architecture. _daily.dev surfaces CDC architecture writeups for teams weighing Kafka against direct lakehouse ingestion._ ### Does the Debezium Zerobus Ingest sink guarantee exactly-once delivery? No, delivery is at-least-once, not exactly-once. If a later group of records fails, an earlier durable group can be redelivered, so duplicates can occur. Each event carries a SHA-256 idempotency_key derived from its destination, partition, key, operation and source position, which you use to deduplicate downstream rather than relying on the sink itself. _Engineers designing CDC dedup logic can track delivery-guarantee details like this on daily.dev._ ### What is envelope mode in the Debezium Zerobus Ingest sink? Envelope mode lands the full Debezium change event into a fixed nine-column table instead of mapping fields onto the source's own schema, as typed mode (the default) does. It was contributed by NVIDIA and preserves the operation, key, value, source position (including the PostgreSQL LSN), and an idempotency key for downstream deduplication and ordering. _daily.dev helps engineers compare CDC ingestion modes before committing to a pipeline design._ ## Similar posts on daily.dev - [Databricks Zerobus: Event Streams \+ The Lakehouse](https://daily.dev/posts/databricks-zerobus-event-streams-the-lakehouse-mh7pztbor) · Confessions of a Data Guy · 1 upvotes · 0 comments - [Building a near real-time application with Zerobus Ingest and Lakebase](https://daily.dev/posts/building-a-near-real-time-application-with-zerobus-ingest-and-lakebase-dfbzeuach) · databricks · 0 upvotes · 0 comments - [Building Kafka-Less Data Integration Pipelines with Debezium](https://daily.dev/posts/building-kafka-less-data-integration-pipelines-with-debezium-5yi0fimdi) · Debezium · 1 upvotes · 0 comments - [Announcing General Availability of Zerobus Ingest, part of Lakeflow Connect](https://daily.dev/posts/announcing-general-availability-of-zerobus-ingest-part-of-lakeflow-connect-0rtyz2hni) · databricks · 0 upvotes · 0 comments - [Debezium in Production: PostgreSQL to Kafka to Iceberg CDC Patterns That Actually Work](https://daily.dev/posts/debezium-in-production-postgresql-to-kafka-to-iceberg-cdc-patterns-that-actually-work-43qqjunc0) · BigData Boutique blog · 3 upvotes · 0 comments --- Tags: [#postgresql](https://daily.dev/tags/postgresql), [#databricks](https://daily.dev/tags/databricks), [#change-data-capture](https://daily.dev/tags/change-data-capture), [#debezium](https://daily.dev/tags/debezium), [#unity-catalog](https://daily.dev/tags/unity-catalog) [View this post on daily.dev](https://daily.dev/posts/push-based-cdc-into-unity-catalog-with-zerobus-ingest-and-debezium-zjvwx1xrw) ```json {"@context":"https://schema.org","@graph":[{"@type":"Organization","@id":"https://daily.dev/#organization","name":"daily.dev","url":"https://daily.dev","logo":{"@type":"ImageObject","url":"https://daily.dev/apple-touch-icon.png","width":180,"height":180},"sameAs":["https://twitter.com/dailydotdev","https://github.com/dailydotdev","https://www.linkedin.com/company/daily-dev-ltd"]},{"@type":"WebSite","@id":"https://daily.dev/#website","url":"https://daily.dev","name":"daily.dev","publisher":{"@id":"https://daily.dev/#organization"},"potentialAction":{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https://daily.dev/search?q={search_term_string}"},"query-input":"required name=search_term_string"}}]} {"@context":"https://schema.org","@type":"TechArticle","headline":"Push-based CDC into Unity Catalog with Zerobus Ingest and Debezium","url":"https://daily.dev/posts/push-based-cdc-into-unity-catalog-with-zerobus-ingest-and-debezium-zjvwx1xrw","mainEntityOfPage":{"@type":"WebPage","@id":"https://daily.dev/posts/push-based-cdc-into-unity-catalog-with-zerobus-ingest-and-debezium-zjvwx1xrw"},"datePublished":"2026-11-05T13:04:20.446Z","dateModified":"2026-11-05T13:04:49.529Z","description":"Debezium Server can stream change data capture events straight into Unity Catalog Delta tables via Databricks Zerobus Ingest, skipping a traditional Kafka...","image":"https://media.daily.dev/image/upload/f_auto,q_auto/v1/posts/b815188ca4799ee6c5c40bfeb2260a97?_a=AQAEuop","thumbnailUrl":"https://media.daily.dev/image/upload/f_auto,q_auto/v1/posts/b815188ca4799ee6c5c40bfeb2260a97?_a=AQAEuop","isAccessibleForFree":true,"articleSection":"databricks","inLanguage":"en","publisher":{"@type":"Organization","name":"daily.dev","url":"https://daily.dev","logo":{"@type":"ImageObject","url":"https://daily.dev/apple-touch-icon.png","width":180,"height":180}},"author":{"@type":"Organization","name":"databricks","logo":"https://media.daily.dev/image/upload/t_logo,f_auto/v1/logos/fa7aa720f2db4d1eba826814730482c8","url":"https://daily.dev/sources/databricks"},"commentCount":0,"discussionUrl":"https://daily.dev/posts/push-based-cdc-into-unity-catalog-with-zerobus-ingest-and-debezium-zjvwx1xrw","interactionStatistic":[{"@type":"InteractionCounter","interactionType":{"@type":"LikeAction"},"userInteractionCount":0},{"@type":"InteractionCounter","interactionType":{"@type":"CommentAction"},"userInteractionCount":0}],"keywords":"postgresql,databricks,change-data-capture,debezium,unity-catalog","timeRequired":"PT9M"} {"@context":"https://schema.org","@type":"BreadcrumbList","itemListElement":[{"@type":"ListItem","position":1,"name":"Home","item":"https://daily.dev"},{"@type":"ListItem","position":2,"name":"databricks","item":"https://daily.dev/sources/databricks"},{"@type":"ListItem","position":3,"name":"Push-based CDC into Unity Catalog with Zerobus Ingest and Debezium"}]} {"@context":"https://schema.org","@type":"FAQPage","@id":"https://daily.dev/posts/push-based-cdc-into-unity-catalog-with-zerobus-ingest-and-debezium-zjvwx1xrw#faq","mainEntity":[{"@type":"Question","name":"How can I stream PostgreSQL CDC changes into Databricks without running Kafka?","acceptedAnswer":{"@type":"Answer","text":"Debezium Server can send change events directly to Databricks Zerobus Ingest, which writes them into Unity Catalog governed Delta tables without any message broker. The open-source Debezium Server Zerobus sink, built by NVIDIA and Databricks, ships in Debezium Server 3.7 and eliminates the two-hop Kafka plus ingestion-job architecture. daily.dev surfaces CDC architecture writeups for teams weighing Kafka against direct lakehouse ingestion."}},{"@type":"Question","name":"Does the Debezium Zerobus Ingest sink guarantee exactly-once delivery?","acceptedAnswer":{"@type":"Answer","text":"No, delivery is at-least-once, not exactly-once. If a later group of records fails, an earlier durable group can be redelivered, so duplicates can occur. Each event carries a SHA-256 idempotency_key derived from its destination, partition, key, operation and source position, which you use to deduplicate downstream rather than relying on the sink itself. Engineers designing CDC dedup logic can track delivery-guarantee details like this on daily.dev."}},{"@type":"Question","name":"What is envelope mode in the Debezium Zerobus Ingest sink?","acceptedAnswer":{"@type":"Answer","text":"Envelope mode lands the full Debezium change event into a fixed nine-column table instead of mapping fields onto the source's own schema, as typed mode (the default) does. It was contributed by NVIDIA and preserves the operation, key, value, source position (including the PostgreSQL LSN), and an idempotency key for downstream deduplication and ordering. daily.dev helps engineers compare CDC ingestion modes before committing to a pipeline design."}}]} ```