You can ingest data from WarpStream, an Apache Kafka-compatible data streaming platform built directly on top of object storage, into RisingWave.
This guide will help you set up WarpStream, ingest data into RisingWave, and create and query a materialized view in RisingWave.
To interact with the WarpStream cluster, install the WarpStream Agent or CLI:
After the installation, run the following commands in the terminal:
In RisingWave, create a source named “website_visits” to connect RisingWave to the WarpStream topic:
In RisingWave, create a materialized view that offers insights into user behavior on different pages for analyzing website traffic and engagement.
Let’s retrieve data from the created materialized view:
Expected result:
You have successfully ingested data from WarpStream into RisingWave, created a materialized view, and queried it in RisingWave.
You can ingest data from WarpStream, an Apache Kafka-compatible data streaming platform built directly on top of object storage, into RisingWave.
This guide will help you set up WarpStream, ingest data into RisingWave, and create and query a materialized view in RisingWave.
To interact with the WarpStream cluster, install the WarpStream Agent or CLI:
After the installation, run the following commands in the terminal:
In RisingWave, create a source named “website_visits” to connect RisingWave to the WarpStream topic:
In RisingWave, create a materialized view that offers insights into user behavior on different pages for analyzing website traffic and engagement.
Let’s retrieve data from the created materialized view:
Expected result:
You have successfully ingested data from WarpStream into RisingWave, created a materialized view, and queried it in RisingWave.