I mean RisingWave, the solution mentioned in the article, is a complete startup rewriting things in Rust mostly to avoid the larger Java solutions like Flink and Spark...
They do work, but they have some sharp and rough edges.
They are rarely supported by real business value.
Save the data as soon as it comes in and transform it in batch mode.