Quickly connect RisingWave to your Apache Kafka broker to start ingesting data.
CREATE SOURCE
(for a connection without storing data) or CREATE TABLE
(for a connection that stores data in RisingWave).
ip:port
).CREATE SOURCE
: Creates a connection without storing data in RisingWave. See Connecting with CREATE SOURCE
for details.CREATE TABLE
: Creates a connection and stores the ingested data in RisingWave. See Connecting with CREATE TABLE
for details.CREATE SOURCE
(data not stored)Field | Default Type | Note |
---|---|---|
key | BYTEA | Can be overwritten by ENCODE and KEY ENCODE. |
timestamp | TIMESTAMP WITH TIME ZONE | Refers to CreateTime (not LogAppendTime). |
partition | VARCHAR | The partition the message is from. |
offset | VARCHAR | The offset in the partition. |
headers | STRUCT<VARCHAR, BYTEA>[] | Key-value pairs (headers) associated with the message. |
payload | JSON | The actual content or data of the message. Only supports JSON format. |