stateful-streaming

Here are 2 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 Sep 16, 2025
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

Improve this page

Add a description, image, and links to the stateful-streaming 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-streaming topic, visit your repo's landing page and select "manage topics."

Learn more

Provide feedback

Saved searches

Use saved searches to filter your results more quickly