For years, Snowflake has been the go-to platform for analytics, but one major gap has remained: real-time, streaming data.

Today, that changes.

We’re thrilled to announce the DeltaStream Application for Snowflake — a native integration that brings real-time streaming data directly into the Snowflake UI.
With this integration, Snowflake users can access Kafka and Kinesis topics, preview live data, run streaming SQL queries, read change data from RDBMS such as Postgres tables, stream data directly into Snowflake tables and many more actions — all from inside Snowflake.

No new tools, no external pipelines, no delays.
Just pure streaming power — delivered through DeltaStream.

Snowflake has set the standard for simplicity and scalability in analytics. Yet, most Snowflake workloads are still batch-oriented — data arrives minutes or hours after it’s created.

Meanwhile, real-time systems like Kafka, Kinesis, and CDC from databases like Postgres continue to generate event streams that power operational and intelligent applications.
These data sources have lived outside Snowflake’s direct reach — until now.

Snowflake users have long wanted to:

  • Explore Kafka and Kinesis data without standing up connectors or ETL jobs
  • Query live, changing streams next to historical data
  • Bring change data streams from transactional databases like Postgres into Snowflake in seconds

The new DeltaStream Application for Snowflake finally makes this possible.

Introducing the DeltaStream Application for Snowflake

The DeltaStream Snowflake application provides a native, interactive streaming experience directly inside the Snowflake UI.

With this integration, you can:

  • 🔍 List and browse live streaming topics in Kafka and Kinesis
  • 👁️ Preview and print messages from specific topics in real time
  • 🧠 Run streaming SQL queries on live data directly inside Snowflake Worksheets
  • ⚙️ Ingest change data (CDC) from Postgres and other databases as continuous streams
  • 💾 Materialize results into Snowflake tables for instant analytics or machine learning pipelines

All of the computation, ingestion, and streaming logic happens in DeltaStream’s real-time engine.
Snowflake acts as the command and visualization interface — giving users one seamless experience for both streaming and batch data.

How It Works

The DeltaStream application extends the Snowflake UI with a SQL-based interface to streaming sources.

This video shows how easy it is to build an end to end streaming pipeline to bring real-time data into Snowflake:

All results are available instantly inside Snowflake, and any derived tables can be materialized as Snowflake tables with continuously fresh data pushed into for further analysis — all through familiar SQL.

Why This Matters

This integration fills a critical gap in the modern data stack.

Until now, Snowflake users couldn’t natively interact with streaming systems. They needed connectors, staging areas, or external orchestration to bring in fresh data. With DeltaStream’s application:

  • Streaming meets analytics — real-time data is now queryable alongside historical tables.
  • No data movement headaches — DeltaStream handles the streaming, Snowflake remains your single workspace.
  • Immediate insights — users can act on the latest data without waiting for pipelines to run.

This enables powerful new use cases:

  • Real-time dashboards from Kafka or Kinesis data
  • Fraud detection and anomaly detection powered by live streams
  • Operational analytics combining fresh events and warehouse data
  • Continuous CDC ingestion from Postgres and MySQL into Snowflake

Powered by DeltaStream Fusion

Under the hood, this experience is powered by DeltaStream Fusion, our real-time context engine that connects to streaming and database sources, runs continuous queries, and exposes live results wherever you need them.

Fusion handles:

  • Stream ingestion and enrichment
  • Stateful streaming joins and aggregations
  • CDC extraction from databases
  • Continuous delivery into downstream systems

Now, with Snowflake integration, all of this happens transparently — while users stay in the Snowflake UI.

A Huge Step Forward for Real-Time Snowflake

This new capability transforms Snowflake into a true real-time data platform — one that’s not limited to static tables or delayed pipelines.

For organizations running on Snowflake, this means:

  • Immediate access to live Kafka, Kinesis, and CDC data
  • Streaming SQL at scale with zero infrastructure overhead
  • Real-time analytics and operational decision-making
  • One unified interface for batch, streaming, and hybrid data

Streaming, Simplified

The DeltaStream Application for Snowflake is now bringing real-time data into the hands of every Snowflake user — no engineering bottlenecks, no new interfaces, no latency.

This is more than an integration — it’s a paradigm shift.
 Streaming data is now as easy to query as a Snowflake table.

Welcome to the new era of real-time Snowflake — powered by DeltaStream.

Try DeltaStream’s free trial at www.deltastream.io and bring your streaming data to life inside Snowflake.

This blog was written by the author with assistance from AI to help with outlining, drafting, or editing.