Product hub

Message Broker

Message Broker documentation is scoped to the private beta temporal broker candidate: local durable ingest, replay, shared queue processing, diagnostics, configured auth modes, and policy-shaped replication with product-bound claim limits.

Current availability

Private Beta. Public beta is scheduled for November 9, 2026.

Private BetaConfirm First

Primary Workflow

1
Create streamsStart with private beta stream management and publish routes.
2
Replay recordsFetch by offset or time, then commit or rewind cursors.
3
Process queuesClaim work, renew leases, ack, nack, retry, or dead-letter records.
4
Inspect limits and compatibility guidanceUse health, metrics, audit, diagnostics, and packet artifacts before strengthening claims.

Surface Status

Private beta candidate

Private Beta

Frame the broker as a single-cluster private beta engineering candidate, with named-pilot readiness still tied to packet completion, accepted gaps, and product signoff.

Streams and replay

Private Beta

Use the native API contract for stream creation, publish, fetch, replay, cursor commit, cursor rewind, and consumer-group inspection wording.

Shared queue processing

Private Beta

Describe claim, ack, nack, renew, retry, and dead-letter operations as shared-queue workflows over the current broker surface.

Observability and diagnostics

Private Beta

Point operators toward health, metrics, audit inspection/export, diagnostics bundle, and release-packet evidence without making support promises.

Replication outcomes

Confirm First

Keep replication status, worker polling, and target-apply route wording separate from cross-site durability or availability outcomes until selected packet evidence is attached.

Route Families

Health and metrics

Health, metrics, audit inspection, audit export, and diagnostics bundle surfaces for pilot evaluation and operations review.

Streams and records

Stream management, publish, fetch, replay, and record inspection through the native broker contract.

Cursors and groups

Cursor commit, cursor rewind, and consumer-group inspection for replay and reader coordination.

Shared queue

Claim, mutation, lease renewal, ack, nack, retry, and dead-letter flows over durable queue state.

Replication

Replication status, worker poll, and target-apply routes with strict claim boundaries for topology-specific outcomes.

Authentication

Configured API-key, mTLS trust-file, or trusted-header external identity modes for non-health routes.

Boundaries to Keep Visible

Private Beta

Present current workflows as evaluated private beta behavior, not as general release support or an unrestricted broker replacement.

Replication Claims

Route-family documentation can name replication status and worker flows, but cross-site outcomes need selected packet evidence and operations review.

Compatibility Claims

Keep Kafka language tied to typed prototype scope until a real listener, client smoke evidence, and accepted matrix row exist.

Auth and Support

Name API-key, mTLS trust-file, or trusted-header modes exactly, and require approved support coverage before publishing commitments.

Safe Next Steps

Available now
Run stream and queue quickstart
Create a stream, publish records, replay data, claim queue work, ack results, and inspect private beta limits.
Available now
Review Message Broker limits
Use the limits and compatibility guidance before strengthening stream, queue, auth, replication, or pilot-readiness claims.
Available
Use Rust SDK examples
Review tested Rust examples for stream publish, replay, cursor commit, shared queue processing, retry, and dead-letter handling.
Available
Read HTTP reference
Find versioned stream, record, cursor, queue, audit, metrics, storage, and replication routes.
Available
Read CLI and SDK reference
Group lifecycle flags, diagnostics, local and remote CLI examples, and Rust SDK entry points.
Available
Compare route and auth scope
Separate private beta routes from auth, replication, queue, CLI, SDK, and Kafka protocol boundaries.
Available
Read known limits
See what happens for Kafka listener, replication outcome, identity, and remote CLI boundaries.
Available
Use operator runbooks
Check health, metrics, audit, diagnostics, storage inspection, quota rejection, replication status boundaries, and support details.