DestinationOpen-Source

Deliver data to Apache Kafka

An open-source distributed event streaming platform

Quick Start

Connect in minutes with SQL

Use CREATE SINK to deliver processed data from RisingWave to Apache Kafka. Define your transformation logic in SQL and let RisingWave handle delivery, retries, and exactly-once semantics.

SQL

CREATE SINK kafka_sink AS
SELECT
    order_status,
    COUNT(*) as order_count,
    SUM(total_amount) as total_revenue,
    AVG(total_amount) as avg_order_value,
    MIN(last_updated) as first_order_time,
    MAX(last_updated) as last_order_time
FROM orders_rw
WITH (
   connector='kafka',
   properties.bootstrap.server='localhost:9092',
   topic='test',
   properties.message.max.bytes = 2000
)
FORMAT PLAIN ENCODE JSON;

For comprehensive configuration details, please refer to the Kafka connector documentation.

Capabilities

What you can do with RisingWave + Apache Kafka

Continuous Delivery

Automatically sink processed results from RisingWave to Apache Kafka as new data arrives. No batch jobs needed.

Exactly-once Semantics

Guaranteed data correctness when delivering to Apache Kafka with barrier-based checkpointing.

Upsert & Append

Support both append-only and upsert modes when sinking to Apache Kafka, depending on your use case.

Sink Decoupling

Built-in buffering ensures RisingWave stays stable even if Apache Kafka experiences temporary slowdowns.

Resources

Learn more

Apache Kafka Destination Connector Documentation

Complete configuration reference, authentication options, and advanced features for the Apache Kafka destination connector.

Apache Kafka as Source

RisingWave also supports Apache Kafka as a source. View the source connector.

RisingWave Quick Start Guide

Get RisingWave running locally in 5 minutes and try your first streaming pipeline.

Start streaming in minutes

Connect to Apache Kafka with just a few lines of SQL. No infrastructure to manage, no code to write.

Start Free All Connectors