S

stream-processing

Real-time connected vehicle telemetry pipeline using Kafka, MongoDB, FastAPI, and Grafana with anomaly detection and fleet monitoring dashboards.

SEDA like framework to design your microservices as a DAG of business functions or stages, without any DSL and in an implementation agnostic manner.

Smart functions for stream processing, fault-tolerance and Java Streams integration of non-streaming APIs and language constructs.