turbine-bench

Side-by-side throughput / CPU benchmarks for Turbine and competing Python stream processors. One directory per product, identical workloads, shared Redpanda + a shared synthetic input topic. The goal is relative comparison, not absolute numbers — all results here are same-machine.

How it works

Each product is benched on its own with the orchestrator:

just bench turbine            # all workloads for a product
just bench quix stateless     # a single workload

Every run measures throughput (from Kafka offsets), CPU/RSS (across the full process tree), and a few order-of-magnitude sanity indicators (selectivity, breach rate) to confirm both sides bench the same thing. Each run is appended to the results store and the comparison pages are regenerated.

Results

See Results for the per-workload comparison (latest result of every product, side by side) and the full run history.

Workloads

Workload	Description
stateless	Filter European regions (eu-*), compute latency_ratio + sla_status decision, republish
windowed	Group-by region, count + avg(latency_ms), tumbling 30 s event-time