Supported sources

This topic lists the source connectors in RisingWave.

Below is a complete list of source connectors in RisingWave. Click a connector name to see the SQL syntax, options, and a sample statement for connecting RisingWave to the connector.

Connector	Version
Kafka	3.1.0 or later
Redpanda	Latest
Pulsar	2.8.0 or later
Kinesis	Latest
PostgreSQL CDC	10, 11, 12, 13, 14
MySQL CDC	5.7, 8.0
SQL Server CDC	2019, 2022
MongoDB CDC
Citus CDC	10.2
CDC via Kafka
Google Pub/Sub
Amazon S3	Latest
Google Cloud Storage	Latest
Azure Blob	Latest
NATS JetStream
MQTT
Apache Iceberg
Load generator	Built-in

For information on supported data formats and encodings, and whether you need to use CREATE SOURCE or CREATE TABLE with each format, see Data formats and encoding options.