Skip to main content

CREATE SOURCE

Sources are resources that RisingWave can read data from. Use CREATE SOURCE to establish the connection to a source. After a connection is established, RisingWave will be able to read data from the source.

Supported sources

Click the source name to see the SQL syntax, options, and sample statement of connecting RisingWave to the source.

SourceVersionData formatMaterialized?Limitations
Kafka3.1.0 or later versionsJSON, protobufMaterialized & non-materialized-
RedpandaLatestJSON, protobufMaterialized & non-materialized-
Pulsar2.8.0 or later versionsJSON, protobufMaterialized & non-materialized-
KinesisLatestJSON, protobufMaterialized & non-materialized-
PostgreSQL CDC10, 11, 12, 13, 14Debezium JSONMaterialized onlyMust have primary key
MySQL CDC5.7, 8.0Debezium JSONMaterialized onlyMust have primary key
note

After connecting to a streaming source, RisingWave will not ingest data until a materialized view is created. After a materialized view is created, RisingWave will start to consume and analyze the data.

Help us make this doc better!