Stream processing

A step of the Cloud application tree on Gradus, in the Data & storage area: DB, cache, queues.

Process events as they arrive with a stream processor, keeping derived views up to date without batch jobs.

Usually comes after: Message queue.

Prompt for your AI assistant

Add a stream processing consumer that builds a derived read model from the existing event stream, with checkpointing so it can resume after a restart.

This is https://gradus.kazet.blog/tree/cloud-application/step/stream-processing as plain HTML. In a browser the page also lets you mark the step forged and copy a message for your AI assistant.