stateful-streaming

Here are 4 public repositories matching this topic...

Menziess / slipstream-async

Slipstream provides a data-flow model to simplify development of stateful streaming applications.

python streaming kafka stream-processing data-engineering dataflow data-processing streaming-data slipstream stateful-streaming

Updated Aug 27, 2026
Python

Harry7890 / stream-aggregator

Star

Stateful stream-processing pipeline implementing tumbling time windows to compute real-time metrics and analytics.

python docker kafka docker-compose stream-processing kafka-topic data-engineering windowing kafka-consumer apache-kafka kafka-producer real-time-data aggregations stateful-streaming

Updated Aug 10, 2026
Python

aimov6464 / distributed-event-processor

Star

Distributed event processing with Apache Spark Structured Streaming: Kafka ingestion, stateful deduplication, watermark-based window aggregation, and reproducible Parquet/Kafka outputs.

java distributed-systems kafka apache-spark stream-processing deduplication watermark exactly-once event-driven-architecture spark-structured-streaming stateful-streaming

Updated Jan 18, 2026
Java

mojtabanorouzie / delayed-order-sms-flink

Star

Apache Flink job that detects orders past their expected delivery time on a Kafka stream and emits idempotent SMS commands. Keyed state, processing-time timers, dead-letter routing, Docker E2E suite.

python java distributed-systems kafka docker-compose stream-processing event-driven apache-flink idempotency dead-letter-queue stateful-streaming

Updated Aug 23, 2026
Java

Add this topic to your repo

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

Learn more