stateful-stream-processing

Here are 4 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 Aug 9, 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 Aug 12, 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.

portfolio spring-boot websocket dynamodb grpc stream-processing pyspark apache-flink apache-kafka event-driven-architecture apache-iceberg stateful-stream-processing

Updated Jan 1, 2026
Java

Improve this page

Add a description, image, and links to the stateful-stream-processing topic page so that developers can more easily learn about it.

Curate this topic

Add this topic to your repo

To associate your repository with the stateful-stream-processing topic, visit your repo's landing page and select "manage topics."

Learn more