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 materialized source, a materialized view, or a table.

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)
• JDBC-available databases
  • MySQL (Supports versions 5.7 and 8.0.x)
  • PostgreSQL
  • TiDB
• Apache Iceberg

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.