Data Streaming Summit 2026 — Registration is Open!

Register Now >
StreamNative Logo

Query Your Streams in SQL.

Postgres-compatible SQL directly on your Kafka and Pulsar topics.

StreamNative SQL Workspace

Topics Become Sources

Query Kafka and Pulsar topics directly — no separate system.

Views That Stay Current

Materialized views update as events arrive. No batch schedule.

Any Postgres Client

psql, DBeaver, BI tools, and agent frameworks connect directly.

What's New

Introducing SQL Workspace in StreamNative Cloud

Query Kafka and Pulsar topics, build continuously updated materialized views, and serve real-time data to applications, BI tools, and AI agents — all with SQL.

Read Announcement

THE OBJECT MODEL

Familiar SQL Concepts for Streaming Data

SQL Workspace, powered by the RisingWave SQL engine, organizes resources using concepts SQL users already know, while preserving what makes streaming valuable: continuous updates, low latency, and the ability to react as events arrive.

Sources

Connect to and read external data, including topics from associated Kafka and Pulsar clusters.

Tables

Persist current data and state for repeatable access.

Materialized Views

Continuously transform incoming events and maintain up-to-date results as source data changes.

Sinks

Send processed data to an external system or destination database.

HOW IT WORKS

From an Interactive Question to Production SQL

Poke at a topic in the browser editor, and when the query is right, leave it running for good — then serve the result to anything that speaks Postgres.

Start with a question, right in the browser

Start with a question, right in the browser

Connect one workspace to multiple clusters, discover streaming data as sources, and write SQL against topics and materialized views from a browser-based editor.

Inspect catalog resources without learning cluster-specific APIs

Filter, join, aggregate, and transform live event streams in SQL

USE CASES

What Teams Build with SQL Workspace

01

Continuously updated order status

Read order, payment, and fulfillment events from Kafka or Pulsar, join them into a materialized view that stays current, and write the result into a database table your customer-service applications already use.

02

Real-time fraud and risk signals

Express detection logic once in SQL and let it run continuously against live event streams, so signals surface as events arrive rather than on the next batch window.

03

Operational metrics and customer profiles

Maintain inventory, operational metrics, and customer profiles as materialized views — no connector infrastructure and no separate processing engine to operate.

04

Fresh context for AI agents

Serve real-time context to agents over the PostgreSQL wire protocol, or retrieve it in natural language through Rio, the AI assistant built into StreamNative Cloud. Agents read the same governed data your applications do.

FAQs

Not yet. SQL Workspace is currently in Private Preview, and Public Preview is coming soon. Contact the StreamNative team to request access.

SQL Workspace is powered by the RisingWave SQL engine. RisingWave provides the streaming SQL foundation for executing continuous queries and incrementally maintaining results as new events arrive, while StreamNative Cloud provides the integrated workspace experience and connectivity to Kafka and Pulsar clusters.

No. SQL Workspace presents Kafka and Pulsar topics directly as queryable sources. You can filter, join, aggregate, and transform live event streams without first copying them into a separate analytical system.

Every SQL Workspace is a PostgreSQL-compatible endpoint, so anything that speaks the PostgreSQL wire protocol can connect. Use psql, DBeaver, your BI tools, application frameworks, or most agent frameworks to query tables and continuously updated materialized views with familiar drivers.

Delete that kafka-to-postgres-sync service

  • Connect a workspace to your existing Kafka and Pulsar clusters.
  • Query your topics as sources from the browser SQL editor.
  • Turn a query into a continuously updated materialized view.