如何使用 Redpanda 进行流处理?

How to do stream processing with Redpanda?

Redpanda 似乎很容易使用,但如何实时处理流?

我们有几千台每秒向我们发送数据的物联网设备。我们想要获取每个设备过去一小时的数据的 运行 平均值。内置的 WebAssembly 东西可以用于此吗,还是我们需要像 Materialize 这样的东西?

鉴于它被标榜为“Kafka 兼容”,任何 Kafka 库都应该与 RedPanda 兼容,包括 Kafka Streams、KSQL、Apache Spark、Flink、Storm 等。