Stream into RisingWave with your free account

The RisingWave materialization connector in Estuary streams data from Estuary collections to RisingWave as Kafka-compatible messages using Dekaf. RisingWave connects to Estuary as a Kafka source, enabling real-time SQL processing, transformations, and continuously updated materialized views without requiring a separate Kafka cluster.

• Kafka-compatible streaming from Estuary collections to RisingWave
• Direct integration with RisingWave’s Kafka source connector
• No separate Kafka cluster required — RisingWave connects directly to Estuary’s Dekaf endpoint
• Avro message encoding for structured streaming data
• Schema Registry support for retrieving the Avro schema
• Configurable Kafka topic names for individual Estuary collection bindings
• Kafka or CDC deletion modes for controlling how deletions are represented
• Optional strict Kafka-compatible topic naming
• SASL/SSL authentication using the Estuary materialization name and an authentication token

RisingWave connects to Estuary using the Dekaf Kafka-compatible endpoint with SASL_SSL and the PLAIN authentication mechanism. After creating the RisingWave source, you can build materialized views using SQL transformations and aggregations over the incoming Estuary data.