CDP Dashboard

—Events/sec
—Total Profiles
—Total Events
Reference Architecture

Real-time Customer Data Platform

From raw clickstream events to live profiles and dashboards. Identity resolution, sessionization, and profile aggregation powered by native Streamr SQL and FlareDB.

Click any component to explore

Event ProducerRust, tokioRedpandaKafka-compatibleStreamrIdentity ResolutionProfile UpdaterSessionizationLifecycle TimersLive UpdatesCommitted KafkaFlareDBSQL analyticsNative StateRocksDB + checkpointsQuery APIGraphQL + WSDashboardLeptos SSR+WASM
Run it yourselfcurl -fsSL https://raw.githubusercontent.com/jasadams/arcstream/main/deploy/install.sh | bash
See live data →

Processing Behavior

Committed Kafka Output
Each native sink commits transactions; application consumers read committed records.
Tenant-scoped Identity
Native state tables retain identity mappings according to Arcstream tenant and identity policies.
Explicit Event Clocks
Replay and live processing preserve source event timestamps and the configured five-second watermark; native windows close when event time advances.
Checkpoint Recovery
Native state and source positions are checkpointed to persistent storage for restart recovery.

Tech Stack

Rust
Application Services
Event producer, business functions, Query API and dashboard
Streamr
Stateful Streaming
Native SQL, state tables, event-time timers and checkpoints
Redpanda
Event Bus
Kafka-compatible input, output and transaction recovery topics
RocksDB
Native State
Disk-backed identity, profile and native session state
FlareDB
Analytics
SQL over events, profiles and completed sessions
Leptos
Frontend Framework
Rust SSR, WASM hydration and reactive signals
GraphQL
API Layer
Typed queries and WebSocket subscriptions

Design Decisions