WarpStream

Streamwarpstream

Kafka-compatible cluster whose stateless agents store all data directly in object storage.

Provider
default
Kind
Stream
Category
Messaging
Properties · 4 set by this component
propertytypevaluesrequiredkind defaultthis component
acksenumnone | leader | quorum | allno—inherited
compactionboolean—nofalseinherited
deliveryenumat-most-once | at-least-once | exactly-oncenoat-least-once▸ at-least-once
idempotentProducer · advancedboolean—nofalseinherited
managedboolean—nofalse▸ true
minInsyncReplicasinteger—no—inherited
objectStore · component propertyenums3 | gcs | azure-blob | s3-compatiblenos3inherited
orderingenumper-key | globalnoper-key▸ per-key
partitionsinteger—no—inherited
replicationFactorinteger—no—inherited
retentionHoursinteger—no—inherited
schemaEnforcedboolean—nofalseinherited
statelessAgents · component propertyboolean—notrueinherited
storageenumephemeral | persistentnopersistent▸ persistent
transactions · advancedboolean—nofalseinherited
zoneAlignedRouting · component propertyboolean—notrueinherited
Rules that apply · 0

Every rule whose selector covers this component's kind or its category. Whether a rule fires depends on the design: its properties, its edges and its groups.

No rule reads this kind yet. That is a gap, not a guarantee.
Use it in a design
nodes:
  - { id: "warpstream", component: "warpstream" }
Other Stream products · 18
Source
# yaml-language-server: $schema=../../schema/component.schema.json
# WarpStream: Kafka-compatible cluster whose stateless agents keep no local disks and stream records
# straight into object storage, so durability and replication come from the object store while the
# metadata lives in a hosted control plane ("WarpStream Architecture").
schemaVersion: "1"
type: "component"
id: "warpstream"
kind: "stream"
provider: "default"
docs: "https://docs.warpstream.com/warpstream/overview/architecture"
defaults:
  delivery: "at-least-once"
  ordering: "per-key"
  storage: "persistent"
  managed: true
properties:
  objectStore:
    type: "enum"
    values: ["s3", "gcs", "azure-blob", "s3-compatible"]
    default: "s3"
  statelessAgents:
    type: "boolean"
    default: true
  zoneAlignedRouting:
    type: "boolean"
    default: true

The same page as markdown, for an agent: /catalogue/components/warpstream.md