The stream

Every agent action and gate decision, as one message on Kafka.

How this page works

Every agent action and gate decision is one message on Kafka (topic dock.actions), keyed by order or request so one order stays in order. A consumer group writes each into PostgreSQL, where the dashboards read it. This page reads the topic itself, through the server.

Live tail newest first, 0 shown, joining the topic…

  1. Joining dock.actions; the last messages of each partition appear in a few seconds.

What each message carries

schema v1

v, eventId, at, kind, key, agentId, orgId, requestId, orderId, rule, value, ok, ledgerSeq, ledgerHash, summary. ledgerSeq and ledgerHash point at the hash-chained ledger entry the event came from, so the stream and the audit record can be checked against each other. Intake steps that can quote a kitchen's memory are shown by kind only.