CREATE SINK

Use the CREATE SINK command to create a sink. A sink is an external target where you can send data processed in RisingWave. You can create a sink from a table or source, or a materialized view.

If your goal is to create an append-only sink, you can use the emit-on-window-close policy when creating the materialized view that you want to sink data from. For details about the policy, see Emit on window close.

Syntax

CREATE SINK [ IF NOT EXISTS ] sink_name
[FROM sink_from | AS select_query]
WITH (
   connector='connector_name',
   connector_parameter = 'value', ...
);

Supported sinks

Click a sink name to see the SQL syntax, options, and sample statement of sinking data from RisingWave to the sink.

• Kafka (Supports versions 3.1.0 or later)
• MySQL (Supports versions 5.7 and 8.0.x)
• PostgreSQL
• AWS Kinesis
• TiDB
• Apache Iceberg
• Delta Lake

See also

DROP SINK — Remove a sink.

SHOW CREATE SINK — Show the SQL statement used to create a sink.

note

Timestamptz values are stored in UTC.

When sinking downstream, timestamptz is represented as a string in the format 2023-11-11 18:30:09.453000.