Instructions on how to use WarpStream with RisingWave.
RisingWave is a distributed SQL streaming database. In this "how-to" we'll show you how you can connect it to WarpStream using the Apache Kafka API to create a stream processing application that performs streaming aggregations using RisingWave materialized views.
First, follow our instructions for running the WarpStream Agent locally. We recommend running the: warpstream demo command since that will automatically generate a Kafka topic with fake click stream data in it for us to consume.
Next, follow the RisingWave Quick Start instructions to install RisingWave locally and connect to it with psql.
Once you have started a RisingWave instance with the risingwave playground command and then connected to it by running psql -h localhost -p 4566 -d dev -U root , create a new table called website_visits:
CREATE MATERIALIZED VIEW visits_stream_mv ASSELECT page_id, count(*) AS total_visits, count(DISTINCT user_id) AS unique_visitors, max(timestamp) AS last_visit_time FROM website_visits_stream GROUP BY page_id;
Finally, query the newly created materialized view:
select*FROM visits_stream_mv;
You should see the view to continue update over time as you reissue the query:
Apache, Apache Kafka, Kafka, and associated open source project names are trademarks of the Apache Software Foundation. Kinesis is a trademark of Amazon Web Services.