Menu

Product hub

Controlled BetaVerification Required

Message Broker

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

Current availability

Private Beta. Public beta is scheduled for .

Primary Workflow

  1. Create streamsStart with controlled-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 evidenceUse health, metrics, audit, diagnostics, and packet artifacts before strengthening claims.

Surface Status

Controlled-beta candidate

Controlled Beta

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

Evidence: Fact sheet: README.md and controlled-beta onboarding package

Streams and replay

Controlled Beta

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

Evidence: Fact sheet: native-api-contract.md

Shared queue processing

Controlled Beta

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

Evidence: Fact sheet: native-api-contract.md

Observability and diagnostics

Controlled Beta

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

Evidence: Fact sheet: README.md

Replication outcomes

Verification Required

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

Evidence: Fact sheet: controlled-beta onboarding package

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

Controlled Beta

Present current workflows as evaluated controlled-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 reviewer-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 controlled-beta limits.

  • Available now

    Review Message Broker evidence

    Use the evidence index before strengthening stream, queue, auth, replication, or pilot-readiness claims.

  • Available: DOCS-059

    Use Rust SDK examples

    Review tested Rust examples for stream publish, replay, cursor commit, shared queue processing, retry, and dead-letter handling.

  • Available: DOCS-031

    Read HTTP reference

    Find versioned stream, record, cursor, queue, audit, metrics, storage, and replication routes.

  • Available: DOCS-032

    Read CLI and SDK reference

    Group lifecycle flags, diagnostics, local and remote CLI examples, and Rust SDK entry points.

  • Available: DOCS-040

    Compare route and auth scope

    Separate controlled-beta routes from auth, replication, queue, CLI, SDK, and Kafka protocol boundaries.

  • Available: DOCS-042

    Read known limits

    See what happens for Kafka listener, replication outcome, identity, and remote CLI boundaries.

  • Available: DOCS-051

    Use operator runbooks

    Check health, metrics, audit, diagnostics, storage inspection, quota rejection, replication status boundaries, and support evidence.