RisingWave (Streaming Database) Connector for AI agents.

Q: How do I use RisingWave to test my data?

You can use the event ingestion tool to push test JSON objects into your tables. This lets you see how your pipeline handles new data without manual CLI work.

Q: Can I run complex JOIN queries on my materialized views?

Yes! Use the executesql tool to run any valid RisingWave SQL query. You can perform complex analytical queries or inspect the results of your real-time aggregations.

Q: How do I check if my Kafka or Pulsar sources are correctly connected?

Use the listsources tool. It queries the internal catalog to provide a list of all external data sources currently configured in your RisingWave instance.

6 live capabilities

Manage real-time streaming pipelines and SQL databases through natural conversation.

Live agent request RisingWave (Streaming Database) / Connector

Waiting for input…

AI Agent

Why people use RisingWave (Streaming Database)

RisingWave Streaming Database Management for Real-Time Data Engineers

With this Connector, you just ask your agent. You can list your sources, execute a quick query, or push a test event without ever leaving your current workspace. You get a clear view of your data topology and pipeline health in seconds.

What Vinkius changes

You get a direct line to your streaming database without leaving your workspace.

Use it from Claude, ChatGPT, Cursor or another AI client you already have.

One account · 5,900+ Connectors

Real-world use case 01

Debugging a stuck pipeline

A data engineer asks the agent to list materialized views to see if a specific view is lagging or failing to update.
Real-world use case 02

Testing a new API

A backend dev uses `ingest_events` to push a mock JSON payload and see if it hits the database correctly.
Real-world use case 03

Schema Discovery

An analyst asks the agent to list all sources to understand what external data is available for a new dashboard.

Complete set · 6capabilities

The complete RisingWave (Streaming Database) capability set.

These are the exact actions your AI can choose when you ask it to work with RisingWave (Streaming Database).

Capability set01 / 02

01—03

3 capabilities in this set.

Part of 6 available through RisingWave (Streaming Database).

01 Capability
Execute sql
Run any SQL statement against your database. Use this to create new tables or perform quick data updates.
02 Capability
Ingest events
Send JSON objects or arrays into a specific table. This is the fastest way to feed test data into your streams.
03 Capability
List materialized views
See all your active materialized views. Use this to check the status of your real-time aggregations.

Capability set02 / 02

04—06

3 capabilities in this set.

Part of 6 available through RisingWave (Streaming Database).

04 Capability
List sinks
Get a list of all configured data sinks. This lets you see where your data ends up after processing.
05 Capability
List sources
View all external data sources. Use this to map out how data enters your streaming pipeline.
06 Capability
List tables
See a list of all your user tables in RisingWave. This helps you get oriented quickly when exploring a new environment.

Set up in minutes

One URL. Then ask RisingWave (Streaming Database) to work.

Claude and ChatGPT only need the Connector URL. Copy it once, add it in settings, and use RisingWave (Streaming Database) from the conversation.

Choose your client

Live preview

Advanced clients IDE · CLI

Claude · Web + desktop

Official guide ↗

Connector URL · ready to paste

Streamable HTTP

https://edge.vinkius.com/vk_preview_POZ197YoiA8LB1iU15GyiwF0QcgyMosQUQ2XSBMS/mcp

Step 01

Open Connectors

In Claude Web or Claude Desktop, open Settings and choose Connectors.
Step 02

Add the URL

Choose Add custom connector, name it RisingWave (Streaming Database), and paste the URL above.
Step 03

Turn it on in chat

Select +, open Connectors, and enable RisingWave (Streaming Database) for the conversation.

ChatGPT · Web + desktop

Official guide ↗

Connector URL · ready to paste

Streamable HTTP

https://edge.vinkius.com/vk_preview_POZ197YoiA8LB1iU15GyiwF0QcgyMosQUQ2XSBMS/mcp

Step 01

Open MCP settings

On desktop, open Settings and MCP servers. On web, open your workspace app or connector settings.
Step 02

Add the URL

Choose Add server with Streamable HTTP, or create a custom MCP app, then paste the RisingWave (Streaming Database) URL.
Step 03

Save and start

Save the connection and enable RisingWave (Streaming Database) in your conversation. Desktop may ask you to restart once.

Cursor · IDE configuration

Official guide ↗

Advanced setup

{
  "mcpServers": {
    "risingwave-streaming-database": {
      "url": "https://edge.vinkius.com/vk_preview_POZ197YoiA8LB1iU15GyiwF0QcgyMosQUQ2XSBMS/mcp"
    }
  }
}

Step 01

Open MCP Settings

Press Cmd+Shift+P (macOS) or Ctrl+Shift+P (Windows/Linux) → search "MCP Settings"
Step 02

Add the server config

Paste the JSON configuration above into the mcp.json file that opens
Step 03

Save the file

Cursor will automatically detect the new Connector
Step 04

Start using RisingWave (Streaming Database)

Open Agent mode in chat and ask: "Using RisingWave (Streaming Database), help me...". 6 tools available

VS Code Copilot · IDE configuration

Official guide ↗

Advanced setup

{
  "mcpServers": {
    "risingwave-streaming-database": {
      "url": "https://edge.vinkius.com/vk_preview_POZ197YoiA8LB1iU15GyiwF0QcgyMosQUQ2XSBMS/mcp"
    }
  }
}

Step 01

Create MCP config

Create a .vscode/mcp.json file in your project root
Step 02

Add the server config

Paste the JSON configuration above
Step 03

Enable Agent mode

Open GitHub Copilot Chat and switch to Agent mode using the dropdown
Step 04

Start using RisingWave (Streaming Database)

Ask Copilot: "Using RisingWave (Streaming Database), help me...". 6 tools available

Windsurf · IDE configuration

Official guide ↗

Advanced setup

{
  "mcpServers": {
    "risingwave-streaming-database": {
      "url": "https://edge.vinkius.com/vk_preview_POZ197YoiA8LB1iU15GyiwF0QcgyMosQUQ2XSBMS/mcp"
    }
  }
}

Step 01

Open MCP Settings

Go to Settings → MCP Configuration or press Cmd+Shift+P and search "MCP"
Step 02

Add the server

Paste the JSON configuration above into mcp_config.json
Step 03

Save and reload

Windsurf will detect the new server automatically
Step 04

Start using RisingWave (Streaming Database)

Open Cascade and ask: "Using RisingWave (Streaming Database), help me...". 6 tools available

Cline · IDE configuration

Official guide ↗

Advanced setup

{
  "mcpServers": {
    "risingwave-streaming-database": {
      "url": "https://edge.vinkius.com/vk_preview_POZ197YoiA8LB1iU15GyiwF0QcgyMosQUQ2XSBMS/mcp"
    }
  }
}

Step 01

Open Cline MCP Settings

Click the Connectors icon in the Cline sidebar panel
Step 02

Add remote server

Click "Add Connector" and paste the configuration above
Step 03

Enable the server

Toggle the server switch to ON
Step 04

Start using RisingWave (Streaming Database)

Ask Cline: "Using RisingWave (Streaming Database), help me...". 6 tools available

Claude Code · Terminal command

Official guide ↗

Advanced setup

claude mcp add risingwave-streaming-database --transport http "https://edge.vinkius.com/vk_preview_POZ197YoiA8LB1iU15GyiwF0QcgyMosQUQ2XSBMS/mcp"

Step 01

Install Claude Code

Run npm install -g @anthropic-ai/claude-code if not already installed
Step 02

Add the Connector

Run the command above in your terminal
Step 03

Verify the connection

Run claude mcp to list connected servers, or type /mcp inside a session
Step 04

Start using RisingWave (Streaming Database)

Ask Claude: "Using RisingWave (Streaming Database), show me...". 6 tools are ready

Where the request belongs

Work RisingWave can move forward.

Built around the request

Data engineers who need to debug streaming pipelines at 2am and backend devs who are tired of manual event testing.

Data Engineer

Verifies streaming logic and inspects materialized views during production deployments.

Backend Developer

Ingests test events and queries tables directly from the code editor.

Analytics Engineer

Explores available data sources and sinks to build real-time dashboards.

Build the capability set

Each Connector adds new actions and data without changing how you work.

Browse Connectors

01 4 capabilities

Materialize (Streaming SQL DB)

Execute streaming SQL, manage compute clusters, and monitor real-time data pipelines directly from your AI agent.

View Connector

02 4 capabilities

QuestDB (Time-Series)

High-performance time-series database for fast SQL queries, data ingestion, and real-time analytics directly from your AI agent.

View Connector

03 4 capabilities

PipeStream

Streamline real-time data flows. create streams, publish events, and fetch historical data directly from your AI agent.

View Connector

04 6 capabilities

Starburst

Connect your AI to Starburst Enterprise. Query federated data lakes, manage access roles, and orchestrate complex data environments seamlessly.

View Connector

05 2 capabilities

ElectricSQL (Sync Engine)

Sync Postgres data to your AI agent in real-time using ElectricSQL's HTTP Sync API. fetch shapes, stream updates, and query subsets.

View Connector

06 8 capabilities

Conduit

Equip your AI agent to observe data streams, manage integration pipelines, and monitor nodes on the Conduit platform.

View Connector

Bring your own AI

Change the model, client or framework. Keep RisingWave connected.

Claude
ChatGPT
Gemini
Cursor
VS Code
Windsurf
ZCode
Cline
Zed
Continue
Kiro
Roo Code
Zencoder
Goose
Void
Augment Code
Amp
Qodo
Tabnine
Pieces
Sourcegraph Cody
JetBrains
Warp
Amazon Q
Antigravity
BoltAI
Raycast
Jan
LM Studio
AnythingLLM
Open WebUI
Msty
Cherry Studio
LibreChat
TypingMind
Chorus
5ire
n8n
LangChain
LlamaIndex
CrewAI
Vercel AI SDK

Before you connect

Questions about RisingWave.

The practical details behind the request, access and result.

What can I do with the RisingWave MCP?

You can manage your streaming database using natural language. This includes running SQL queries, ingesting JSON events, and listing your tables, sources, and sinks.

How do I use RisingWave to test my data?

You can use the event ingestion capability to push test JSON objects into your tables. This lets you see how your pipeline handles new data without manual CLI work.

Can I run SQL queries through the RisingWave MCP?

Yes, you can execute DDL and DML statements like CREATE, SELECT, and INSERT directly through your AI client.

How does this help with streaming pipelines?

It gives you a way to monitor your materialized views and data sinks quickly. You can see the status of your real-time data flow without switching apps.

Can I see my data sources?

Yes, the Connector can list all external data sources connected to your RisingWave instance so you can see your data topology.

Is this for production databases?

It is designed to help you manage and interact with your RisingWave streaming database. It's great for both development testing and production monitoring.

Can I run complex JOIN queries on my materialized views?

Yes! Use the execute_sql capability to run any valid RisingWave SQL query. You can perform complex analytical queries or inspect the results of your real-time aggregations.

How do I check if my Kafka or Pulsar sources are correctly connected?

Use the list_sources capability. It queries the internal catalog to provide a list of all external data sources currently configured in your RisingWave instance.

Is there a way to push data directly into a table without using an external source?

Absolutely. Use the ingest_events capability to send JSON objects or arrays directly to a specific table via the Events API, perfect for testing or low-latency ingestion.

One connection away

Give your agent a direct line to RisingWave.

Connect RisingWave once. Keep it beside 5,900+ managed Connectors when the next task needs more.

Explore every Connector No credit card required · Free tier available

RisingWave Streaming Database Management for Real-Time Data Engineers

You get a direct line to your streaming database without leaving your workspace.

Debugging a stuck pipeline

Testing a new API

Schema Discovery

Execute sql

Ingest events

List materialized views

List sinks

List sources

List tables

Open Connectors

Add the URL

Turn it on in chat

Open MCP settings

Add the URL

Save and start

Open MCP Settings

Add the server config

Save the file

Start using RisingWave (Streaming Database)

Create MCP config

Add the server config

Enable Agent mode

Start using RisingWave (Streaming Database)

Open MCP Settings

Add the server

Save and reload

Start using RisingWave (Streaming Database)

Open Cline MCP Settings

Add remote server

Enable the server

Start using RisingWave (Streaming Database)

Install Claude Code

Add the Connector

Verify the connection

Start using RisingWave (Streaming Database)

Data Engineer

Backend Developer

Analytics Engineer

Materialize (Streaming SQL DB)

QuestDB (Time-Series)

PipeStream

Starburst

ElectricSQL (Sync Engine)

Conduit

Give your agent a direct line to RisingWave.