Non-Blocking I/O
Built on Spring WebFlux and Project Reactor. The entire ingestion path is fully asynchronous — zero JVM thread blocking on the hot path for both reads and writes.
Real-Time Telemetry, Reimagined.
A self-hosted, non-blocking telemetry ingestion and analytics engine. Ingest millions of events with sub-15ms latency, buffer in Redis, and persist to PostgreSQL — all without a single blocked thread.
Try the live demo
Built on Spring WebFlux and Project Reactor. The entire ingestion path is fully asynchronous — zero JVM thread blocking on the hot path for both reads and writes.
Events are atomically queued via RPUSH and drained in bulk by a background sweeper. The API returns 202 Accepted before any database interaction occurs.
A single INSERT ... VALUES per batch cycle via R2DBC — not N individual inserts. Schema managed automatically by Flyway on startup.
Failed database batches are never dropped. They are preserved in a Redis DLQ for inspection and replay. Zero silent data loss, ever.
Token bucket algorithm backed by Redis. Works correctly across multiple instances with symmetric API key authentication and mtx_pub_ prefix enforcement.
Custom ingestion counters and batch size histograms exposed at /actuator/prometheus. Structured JSON logging compatible with Datadog, ELK, and Grafana Loki.