stateful-processing

Here are 3 public repositories matching this topic...

isinghabhishek / streaming_pipeline

A production-grade real-time streaming pipeline ingesting multi-source events (REST, IoT, WebSocket) into Apache Kafka (Avro & Schema Registry), statefully processing streams via Apache Flink with exactly-once Delta Lake storage, dbt transformations, and Grafana dashboards.

python java avro schema-registry docker-compose grafana pyspark data-engineering event-driven apache-flink apache-kafka dbt real-time-streaming exactly-once delta-lake stateful-processing

Updated Aug 9, 2026
Java

iht / beam-keyed-stream-sorting

Star

Demonstrates architectural pattern implementations in Apache Beam (Java SDK) to restore event-time ordering on out-of-order keyed streams.

java stream-processing dataflow apache-beam beam-summit stateful-processing event-time out-of-order-data session-windows

Updated Sep 1, 2026
Java

iht / beam-college-2026

Star

Apache Beam pipeline demonstrating a two-tiered state architecture for high-performance entity building and session reconstruction from out-of-order streaming events. Official demo for Beam College 2026 talk.

java demo streaming cache data-engineering apache-beam sessionization stateful-processing beam-college out-of-order-events

Updated Aug 31, 2026
Java

Add this topic to your repo

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

Learn more