---
id: "stream"
type: "kind"
category: "messaging"
url: "https://localhost:3000/catalogue/kinds/stream"
---

# Stream

Partitioned, replayable, durable log read by offset.

| | |
|---|---|
| Category | Messaging |
| Properties | 13 |
| Components | 19 |
| Rules | 0 |

## Properties

| property | type | values | required | default |
|---|---|---|---|---|
| `acks` | enum | `none`, `leader`, `quorum`, `all` | no | — |
| `compaction` | boolean | — | no | false |
| `delivery` | enum | `at-most-once`, `at-least-once`, `exactly-once` | no | "at-least-once" |
| `idempotentProducer` (advanced) | boolean | — | no | false |
| `managed` | boolean | — | no | false |
| `minInsyncReplicas` | integer | — | no | — |
| `ordering` | enum | `per-key`, `global` | no | "per-key" |
| `partitions` | integer | — | no | — |
| `replicationFactor` | integer | — | no | — |
| `retentionHours` | integer | — | no | — |
| `schemaEnforced` | boolean | — | no | false |
| `storage` | enum | `ephemeral`, `persistent` | no | "persistent" |
| `transactions` (advanced) | boolean | — | no | false |

## Rules for this kind · 0

No rule selects this kind or its category.

## Components · 19

### vendor-neutral

- [Generic stream](https://localhost:3000/catalogue/components/stream.md) `stream` — the kind itself

### alibabacloud

- [DataHub](https://localhost:3000/catalogue/components/alibaba-datahub.md) `alibaba-datahub` — 4 defaults
- [ApsaraMQ for Kafka](https://localhost:3000/catalogue/components/alibaba-kafka.md) `alibaba-kafka` — 4 defaults

### aws

- [Amazon Kinesis Video Streams](https://localhost:3000/catalogue/components/aws-kinesis-video-streams.md) `aws-kinesis-video-streams` — 7 defaults
- [Amazon Managed Streaming for Apache Kafka](https://localhost:3000/catalogue/components/aws-msk.md) `aws-msk` — 9 defaults
- [Amazon Kinesis Data Streams](https://localhost:3000/catalogue/components/kinesis.md) `kinesis` — 7 defaults

### azure

- [Azure Event Hubs](https://localhost:3000/catalogue/components/azure-event-hubs.md) `azure-event-hubs` — 8 defaults

### default

- [AutoMQ](https://localhost:3000/catalogue/components/automq.md) `automq` — 5 defaults
- [Confluent Cloud](https://localhost:3000/catalogue/components/confluent-cloud.md) `confluent-cloud` — 9 defaults
- [Apache Kafka](https://localhost:3000/catalogue/components/kafka.md) `kafka` — 8 defaults
- [NATS JetStream](https://localhost:3000/catalogue/components/nats-jetstream.md) `nats-jetstream` — 6 defaults
- [Apache Pulsar](https://localhost:3000/catalogue/components/pulsar.md) `pulsar` — 7 defaults
- [Redpanda](https://localhost:3000/catalogue/components/redpanda.md) `redpanda` — 8 defaults
- [Apache RocketMQ](https://localhost:3000/catalogue/components/rocketmq.md) `rocketmq` — 5 defaults
- [WarpStream](https://localhost:3000/catalogue/components/warpstream.md) `warpstream` — 4 defaults

### gcp

- [Managed Service for Apache Kafka](https://localhost:3000/catalogue/components/google-managed-kafka.md) `google-managed-kafka` — 4 defaults

### ibm

- [IBM Event Streams](https://localhost:3000/catalogue/components/ibm-event-streams.md) `ibm-event-streams` — 4 defaults

### oci

- [OCI Streaming](https://localhost:3000/catalogue/components/oci-streaming.md) `oci-streaming` — 5 defaults
- [OCI Streaming with Apache Kafka](https://localhost:3000/catalogue/components/oci-streaming-kafka.md) `oci-streaming-kafka` — 4 defaults

## Source (`kind` YAML, verbatim)

```yaml
# yaml-language-server: $schema=../schema/kind.schema.json
# Partitioned, replayable, durable log (Kafka, Kinesis, Event Hubs). Consumers read by offset.
# Durability knobs (acks, minInsyncReplicas, storage) exist so rules can catch false durability.
schemaVersion: "1"
type: "kind"
id: "stream"
category: "messaging"
properties:
  delivery:
    type: "enum"
    values: ["at-most-once", "at-least-once", "exactly-once"]
    default: "at-least-once"
  ordering:
    type: "enum"
    values: ["per-key", "global"]
    default: "per-key"
  partitions:
    type: "integer"
  replicationFactor:
    type: "integer"
  minInsyncReplicas:
    type: "integer"
  acks:
    type: "enum"
    values: ["none", "leader", "quorum", "all"]
  retentionHours:
    type: "integer"
  compaction:
    type: "boolean"
    default: false
  idempotentProducer:
    type: "boolean"
    default: false
    advanced: true
  transactions:
    type: "boolean"
    default: false
    advanced: true
  storage:
    type: "enum"
    values: ["ephemeral", "persistent"]
    default: "persistent"
  managed:
    type: "boolean"
    default: false
  schemaEnforced:
    type: "boolean"
    default: false
```

Human page: https://localhost:3000/catalogue/kinds/stream