Stream-Processing

A Stream Processing System with State Disaggregation

We've created a cutting-edge prototype for a disaggregated data stream processing system using a standalone control plane, allowing task-state separation. The control plane serves as a routing table for state access, enabling seamless job reconfiguration without causing any downtime or disruption. ***Tech Stack: Java, gRPC, RocksDB, Etcd, Docker Compose, Prometheus, Grafana***