Arroyo, the stream processing engine that runs SQL over real time data streams, ready to accept its first pipeline the moment it boots.
Arroyo is a distributed stream processing engine that lets you express real time data processing as SQL. Instead of building and operating a bespoke streaming application, you write a query and Arroyo turns it into a stateful, fault tolerant pipeline that runs continuously over events as they arrive. It supports event time semantics with watermarks, tumbling, hopping and sliding windows, streaming joins, stateful aggregation, user defined functions and exactly once processing backed by periodic checkpointing, so results stay correct across restarts and late arriving data.
Pipelines are authored in a browser based console with a SQL editor, live query preview, a visual pipeline graph and per operator throughput and checkpoint metrics. Built in sources and sinks connect to Kafka, Redpanda, Kinesis, Pulsar, MQTT, NATS, WebSockets, server sent events, Delta Lake, Iceberg and object storage, so it fits alongside the systems streaming data already lives in.
cloudimg delivers Arroyo fully installed behind an nginx reverse proxy as a self contained single node cluster, so a working engine answers the moment the instance boots with no external database to provision. The image is secure by default and carries no usable login. Arroyo ships with no authentication of its own and, out of the box, every one of its services listens on all network interfaces; cloudimg binds all of them to loopback so the reverse proxy is the only public listener, then adds two layers of access control. On the first boot of every instance a one shot service generates a random console password and a separate engine key unique to that instance, writing them to a file only the root user can read, so no credential is ever baked into the image. The base is fully patched with unattended security upgrades enabled, and every deployment is paired with a step by step deploy guide and backed by 24/7 cloudimg support.
Real screenshots taken while testing this image against its deployment guide.