---
id: "rocketmq"
type: "component"
kind: "stream"
provider: "default"
category: "messaging"
docs: "https://rocketmq.apache.org/docs/introduction/03limits"
url: "https://localhost:3000/catalogue/components/rocketmq"
---

# Apache RocketMQ

Distributed messaging and streaming platform with FIFO, delay and transactional message types.

| | |
|---|---|
| Provider | [default](https://localhost:3000/catalogue?provider=default) |
| Kind | [Stream](https://localhost:3000/catalogue/kinds/stream) |
| Category | Messaging |
| Official docs | [https://rocketmq.apache.org/docs/introduction/03limits](https://rocketmq.apache.org/docs/introduction/03limits) |

## Properties

| property | type | values | required | kind default | this component |
|---|---|---|---|---|---|
| `acks` | enum | `none`, `leader`, `quorum`, `all` | no | — | inherited |
| `compaction` | boolean | — | no | false | inherited |
| `delivery` | enum | `at-most-once`, `at-least-once`, `exactly-once` | no | "at-least-once" | **"at-least-once"** |
| `idempotentProducer` (advanced) | boolean | — | no | false | inherited |
| `managed` | boolean | — | no | false | **false** |
| `maxConsumeRetries` | integer | — | no | 16 | inherited |
| `messageType` | enum | `normal`, `fifo`, `delay`, `transaction` | no | "normal" | inherited |
| `minInsyncReplicas` | integer | — | no | — | inherited |
| `ordering` | enum | `per-key`, `global` | no | "per-key" | **"per-key"** |
| `partitions` | integer | — | no | — | inherited |
| `replicationFactor` | integer | — | no | — | inherited |
| `replicationMode` | enum | `single-replica`, `async-master-slave`, `sync-dual-write`, `auto-failover` | no | "single-replica" | inherited |
| `retentionHours` | integer | — | no | — | inherited |
| `schemaEnforced` | boolean | — | no | false | inherited |
| `storage` | enum | `ephemeral`, `persistent` | no | "persistent" | **"persistent"** |
| `transactions` (advanced) | boolean | — | no | false | **true** |

Bold values are the ones this component pins.

## Rules that apply · 0

No rule selects this kind or its category.

## Other products of the same kind · 18

- [DataHub](https://localhost:3000/catalogue/components/alibaba-datahub.md) `alibaba-datahub` — alibabacloud
- [ApsaraMQ for Kafka](https://localhost:3000/catalogue/components/alibaba-kafka.md) `alibaba-kafka` — alibabacloud
- [Amazon Kinesis Video Streams](https://localhost:3000/catalogue/components/aws-kinesis-video-streams.md) `aws-kinesis-video-streams` — aws
- [Amazon Managed Streaming for Apache Kafka](https://localhost:3000/catalogue/components/aws-msk.md) `aws-msk` — aws
- [Amazon Kinesis Data Streams](https://localhost:3000/catalogue/components/kinesis.md) `kinesis` — aws
- [Azure Event Hubs](https://localhost:3000/catalogue/components/azure-event-hubs.md) `azure-event-hubs` — azure
- [AutoMQ](https://localhost:3000/catalogue/components/automq.md) `automq` — default
- [Confluent Cloud](https://localhost:3000/catalogue/components/confluent-cloud.md) `confluent-cloud` — default
- [Apache Kafka](https://localhost:3000/catalogue/components/kafka.md) `kafka` — default
- [NATS JetStream](https://localhost:3000/catalogue/components/nats-jetstream.md) `nats-jetstream` — default
- [Apache Pulsar](https://localhost:3000/catalogue/components/pulsar.md) `pulsar` — default
- [Redpanda](https://localhost:3000/catalogue/components/redpanda.md) `redpanda` — default
- [Generic stream](https://localhost:3000/catalogue/components/stream.md) `stream` — default
- [WarpStream](https://localhost:3000/catalogue/components/warpstream.md) `warpstream` — default
- [Managed Service for Apache Kafka](https://localhost:3000/catalogue/components/google-managed-kafka.md) `google-managed-kafka` — gcp
- [IBM Event Streams](https://localhost:3000/catalogue/components/ibm-event-streams.md) `ibm-event-streams` — ibm
- [OCI Streaming](https://localhost:3000/catalogue/components/oci-streaming.md) `oci-streaming` — oci
- [OCI Streaming with Apache Kafka](https://localhost:3000/catalogue/components/oci-streaming-kafka.md) `oci-streaming-kafka` — oci

## Use it in a design

```yaml
nodes:
  - { id: "rocketmq", component: "rocketmq" }
```

## Source (`component` YAML, verbatim)

```yaml
# yaml-language-server: $schema=../../schema/component.schema.json
# Apache RocketMQ: partitioned log with per-MessageQueue FIFO order; NORMAL is the default message
# type and consumption retries default to 16 before the dead-letter topic ("Parameter Constraints and
# Suggestions", "Basic Concepts", "Deployment Method").
schemaVersion: "1"
type: "component"
id: "rocketmq"
kind: "stream"
provider: "default"
docs: "https://rocketmq.apache.org/docs/introduction/03limits"
defaults:
  delivery: "at-least-once"
  ordering: "per-key"
  storage: "persistent"
  transactions: true
  managed: false
properties:
  messageType:
    type: "enum"
    values: ["normal", "fifo", "delay", "transaction"]
    default: "normal"
  maxConsumeRetries:
    type: "integer"
    default: 16
  replicationMode:
    type: "enum"
    values: ["single-replica", "async-master-slave", "sync-dual-write", "auto-failover"]
    default: "single-replica"
```

Human page: https://localhost:3000/catalogue/components/rocketmq