Stream

Partitioned, replayable, durable log read by offset.

Category: Messaging
Properties: 13
Components: 19
Rules: 0

Properties · 13 defined by this kind

A node of this kind resolves each property from its own props, then the component's defaults, then the default below.

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. Governance calls that a recorded gap.

Components · 19

vendor-neutral

Generic streamstreamgenericthe kind itself

alibabacloud

DataHubalibaba-datahub4 defaults ApsaraMQ for Kafkaalibaba-kafka4 defaults

aws

Amazon Kinesis Video Streamsaws-kinesis-video-streams7 defaults Amazon Managed Streaming for Apache Kafkaaws-msk9 defaults Amazon Kinesis Data Streamskinesis7 defaults

azure

Azure Event Hubsazure-event-hubs8 defaults

default

AutoMQautomq5 defaults Confluent Cloudconfluent-cloud9 defaults Apache Kafkakafka8 defaults NATS JetStreamnats-jetstream6 defaults Apache Pulsarpulsar7 defaults Redpandaredpanda8 defaults Apache RocketMQrocketmq5 defaults WarpStreamwarpstream4 defaults

gcp

Managed Service for Apache Kafkagoogle-managed-kafka4 defaults

ibm

IBM Event Streamsibm-event-streams4 defaults

oci

OCI Streamingoci-streaming5 defaults OCI Streaming with Apache Kafkaoci-streaming-kafka4 defaults

Source

1# yaml-language-server: $schema=../schema/kind.schema.json
2# Partitioned, replayable, durable log (Kafka, Kinesis, Event Hubs). Consumers read by offset.
3# Durability knobs (acks, minInsyncReplicas, storage) exist so rules can catch false durability.
4schemaVersion: "1"
5type: "kind"
6id: "stream"
7category: "messaging"
8properties:
9  delivery:
10    type: "enum"
11    values: ["at-most-once", "at-least-once", "exactly-once"]
12    default: "at-least-once"
13  ordering:
14    type: "enum"
15    values: ["per-key", "global"]
16    default: "per-key"
17  partitions:
18    type: "integer"
19  replicationFactor:
20    type: "integer"
21  minInsyncReplicas:
22    type: "integer"
23  acks:
24    type: "enum"
25    values: ["none", "leader", "quorum", "all"]
26  retentionHours:
27    type: "integer"
28  compaction:
29    type: "boolean"
30    default: false
31  idempotentProducer:
32    type: "boolean"
33    default: false
34    advanced: true
35  transactions:
36    type: "boolean"
37    default: false
38    advanced: true
39  storage:
40    type: "enum"
41    values: ["ephemeral", "persistent"]
42    default: "persistent"
43  managed:
44    type: "boolean"
45    default: false
46  schemaEnforced:
47    type: "boolean"
48    default: false

The same page as markdown, for an agent: /catalogue/kinds/stream.md