stateful-stream-processing

Here are 5 public repositories matching this topic...

kzmlabs / flink-statefun

Stateful actors on Apache Flink 2.x and Java 21 — durable per-key state, exactly-once messaging, Kafka and Kinesis I/O, Kubernetes-native deployment. Continues the Apache Stateful Functions programming model on the modern Flink line.

Updated Oct 11, 2026
Java

kzmlabs / awesome-statefun

Star

A curated list of resources, libraries, runtimes, SDKs, and learning material for Apache Stateful Functions and stateful actor frameworks on Apache Flink.

kubernetes distributed-systems awesome kafka actor-model kinesis stream-processing awesome-list apache-flink curated-list event-driven-architecture statefun stateful-functions durable-execution stateful-stream-processing

Updated May 3, 2026

yuchen-ecnu / klein

Star

Stateful stream processing on Ray

python distributed-systems stream-processing ray stateful-stream-processing

Updated Oct 10, 2026
Python

rajeev-chaurasia / pulse

Star

Spots mutual matches the moment they happen. Swipes arrive over gRPC, a Flink job holds each pair's state for 15 days and fires when a like is returned, and matches land in DynamoDB and on a live dashboard.