Apache RocketMQ

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

Provider: default
Kind: Stream
Category: Messaging
Official docs: https://rocketmq.apache.org/docs/introduction/03limits

Properties · 5 set by this component

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 · component property	integer	—	no	16	inherited
messageType · component property	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 · component property	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

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: "rocketmq", component: "rocketmq" }

Other Stream products · 18

DataHubalibaba-datahubalibabacloudstream ApsaraMQ for Kafkaalibaba-kafkaalibabacloudstream Amazon Kinesis Video Streamsaws-kinesis-video-streamsawsstream Amazon Managed Streaming for Apache Kafkaaws-mskawsstream Amazon Kinesis Data Streamskinesisawsstream Azure Event Hubsazure-event-hubsazurestream AutoMQautomqstream Confluent Cloudconfluent-cloudstream Apache Kafkakafkastream NATS JetStreamnats-jetstreamstream Apache Pulsarpulsarstream Redpandaredpandastream Generic streamstreamstream WarpStreamwarpstreamstream Managed Service for Apache Kafkagoogle-managed-kafkagcpstream IBM Event Streamsibm-event-streamsibmstream OCI Streamingoci-streamingocistream OCI Streaming with Apache Kafkaoci-streaming-kafkaocistream

Source

1# yaml-language-server: $schema=../../schema/component.schema.json
2# Apache RocketMQ: partitioned log with per-MessageQueue FIFO order; NORMAL is the default message
3# type and consumption retries default to 16 before the dead-letter topic ("Parameter Constraints and
4# Suggestions", "Basic Concepts", "Deployment Method").
5schemaVersion: "1"
6type: "component"
7id: "rocketmq"
8kind: "stream"
9provider: "default"
10docs: "https://rocketmq.apache.org/docs/introduction/03limits"
11defaults:
12  delivery: "at-least-once"
13  ordering: "per-key"
14  storage: "persistent"
15  transactions: true
16  managed: false
17properties:
18  messageType:
19    type: "enum"
20    values: ["normal", "fifo", "delay", "transaction"]
21    default: "normal"
22  maxConsumeRetries:
23    type: "integer"
24    default: 16
25  replicationMode:
26    type: "enum"
27    values: ["single-replica", "async-master-slave", "sync-dual-write", "auto-failover"]
28    default: "single-replica"

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