Generate CREATE SOURCE and CREATE TABLE for Kafka topics
Specify Kafka cluster connection details and message consumption starting point.
List of Kafka broker addresses (host:port).
One topic per source.
Where to start consuming messages.
Configure authentication based on your Kafka cluster's security settings.
Select authentication method for Kafka connection.
FORMAT and ENCODE are independent options. Use INCLUDE to extract Kafka metadata like keys, timestamps, partitions, and offsets.
Format describes the structure of the data (PLAIN for append-only, UPSERT for updates/deletes, DEBEZIUM for CDC). Note: UPSERT is only applicable to CREATE TABLE.
(Extract Kafka message key as a column. Required for UPSERT format.)
(Extract Kafka message timestamp as a TIMESTAMPTZ column.)
(Extract Kafka partition number as a VARCHAR column.)
(Extract Kafka message offset as a VARCHAR column.)
(Extract Kafka message headers as columns (requires specifying header names).)
(Include the raw message payload as a BYTEA column when upstream schema is unknown.)
Encode specifies how data is serialized.
Choose CREATE SOURCE for external data access or CREATE TABLE to materialize and persist data in RisingWave.
Fill in the required fields on the left to generate your RisingWave SQL statement. The preview will update automatically as you enter information.
💡 Quick Start: