Apache RocketMQ logo

Apache RocketMQ

Apache RocketMQ is a distributed messaging and streaming platform with low latency, high performance, and reliability. It provides trillion-level message capacity with rich message types including normal, transactional, delayed, and ordered messages.

1 APIs 4 Capabilities 7 Features 42.1 / 100 thin
Cloud NativeMessagingMessage QueuePub-SubStreamingApacheOpen Source

API Rating

42.1/ 100
thin
Scored 2026-05-20 · rubric v0.3
Discoverability80.0
Contract Quality59.8
Governance39.5
Operational Transparency36.8
Developer Ergonomics8.7
Commercial Clarity39.5

APIs

Apache RocketMQ

RocketMQ provides producer and consumer APIs with client SDKs in Java, Go, Python, C++, C#, Node.js, and Rust, along with a REST API and gRPC-based remoting for message operatio...

Capabilities

Apache RocketMQ REST API — Brokers

Apache RocketMQ REST API — Brokers. 1 operations. Lead operation: Apache RocketMQ List Brokers. Self-contained Naftiko capability covering one Apache Rocketmq business surface.

Run with Naftiko

Apache RocketMQ REST API — ConsumerGroups

Apache RocketMQ REST API — ConsumerGroups. 2 operations. Lead operation: Apache RocketMQ List Consumer Groups. Self-contained Naftiko capability covering one Apache Rocketmq bus...

Run with Naftiko

Apache RocketMQ REST API — Messages

Apache RocketMQ REST API — Messages. 3 operations. Lead operation: Apache RocketMQ Send Message. Self-contained Naftiko capability covering one Apache Rocketmq business surface.

Run with Naftiko

Apache RocketMQ REST API — Topics

Apache RocketMQ REST API — Topics. 4 operations. Lead operation: Apache RocketMQ List Topics. Self-contained Naftiko capability covering one Apache Rocketmq business surface.

Run with Naftiko

Features

High Throughput

Billion-level message throughput with low latency

Multiple Message Types

Normal, ordered, delayed, transactional, and batch messages

Message Filtering

Server-side tag and SQL expression filtering

Exactly-Once Semantics

Transactional messages for exactly-once delivery

Delayed Messages

Schedule messages with configurable delay levels

Dead Letter Queue

Automatic dead letter queue for failed messages

Message Tracing

End-to-end message tracing for debugging and monitoring

Use Cases

Order Processing

Ensure ordered processing of e-commerce order events

Event-Driven Microservices

Decouple microservices with reliable asynchronous messaging

Log Aggregation

Aggregate application logs from distributed services

Financial Transactions

Reliable transactional messaging for financial systems

Integrations

Spring Boot

RocketMQ Spring Boot starter for easy integration

Apache Flink

Flink connector for stream processing from RocketMQ

Apache Spark

Spark Streaming connector for RocketMQ

Kubernetes

RocketMQ Operator for Kubernetes-native deployment

Semantic Vocabularies

Apache Rocketmq Context

14 classes · 34 properties

JSON-LD

API Governance Rules

Apache RocketMQ API Rules

6 rules · 4 errors 2 warnings

SPECTRAL

Resources

👥
GitHubOrganization
GitHubOrganization
🔗
Documentation
Documentation
🔗
SpectralRules
SpectralRules
🔗
Vocabulary
Vocabulary
🔗
JSONLD
JSONLD

Sources

Raw ↑ 
aid: apache-rocketmq
name: Apache RocketMQ
description: Apache RocketMQ is a distributed messaging and streaming platform with low latency, high performance, and reliability.
  It provides trillion-level message capacity with rich message types including normal, transactional, delayed, and ordered
  messages.
type: Index
position: Consumer
access: 3rd-Party
image: https://kinlane-productions2.s3.amazonaws.com/apis-json/apis-json-logo.jpg
tags:
- Cloud Native
- Messaging
- Message Queue
- Pub-Sub
- Streaming
- Apache
- Open Source
created: '2026-03-16'
modified: '2026-05-19'
url: https://raw.githubusercontent.com/api-evangelist/apache-rocketmq/refs/heads/main/apis.yml
specificationVersion: '0.19'
apis:
- aid: apache-rocketmq:apache-rocketmq
  name: Apache RocketMQ
  description: RocketMQ provides producer and consumer APIs with client SDKs in Java, Go, Python, C++, C#, Node.js, and Rust,
    along with a REST API and gRPC-based remoting for message operations, topic management, and cluster administration.
  humanURL: https://rocketmq.apache.org/docs/
  tags:
  - Cloud Native
  - Messaging
  - REST
  - Apache
  - Open Source
  properties:
  - type: Documentation
    url: https://rocketmq.apache.org/docs/
  - type: OpenAPI
    url: openapi/apache-rocketmq-rest-api.yaml
  - type: NaftikoCapability
    url: capabilities/rest-brokers.yaml
  - type: NaftikoCapability
    url: capabilities/rest-consumergroups.yaml
  - type: NaftikoCapability
    url: capabilities/rest-messages.yaml
  - type: NaftikoCapability
    url: capabilities/rest-topics.yaml
maintainers:
- FN: Kin Lane
  email: [email protected]
common:
- type: GitHubOrganization
  url: https://github.com/apache/rocketmq
- type: Documentation
  url: https://rocketmq.apache.org/
- type: SpectralRules
  url: rules/apache-rocketmq-spectral-rules.yml
- type: Vocabulary
  url: vocabulary/apache-rocketmq-vocabulary.yaml
- type: JSONLD
  url: json-ld/apache-rocketmq-context.jsonld
- type: Features
  data:
  - name: High Throughput
    description: Billion-level message throughput with low latency
  - name: Multiple Message Types
    description: Normal, ordered, delayed, transactional, and batch messages
  - name: Message Filtering
    description: Server-side tag and SQL expression filtering
  - name: Exactly-Once Semantics
    description: Transactional messages for exactly-once delivery
  - name: Delayed Messages
    description: Schedule messages with configurable delay levels
  - name: Dead Letter Queue
    description: Automatic dead letter queue for failed messages
  - name: Message Tracing
    description: End-to-end message tracing for debugging and monitoring
- type: UseCases
  data:
  - name: Order Processing
    description: Ensure ordered processing of e-commerce order events
  - name: Event-Driven Microservices
    description: Decouple microservices with reliable asynchronous messaging
  - name: Log Aggregation
    description: Aggregate application logs from distributed services
  - name: Financial Transactions
    description: Reliable transactional messaging for financial systems
- type: Integrations
  data:
  - name: Spring Boot
    description: RocketMQ Spring Boot starter for easy integration
  - name: Apache Flink
    description: Flink connector for stream processing from RocketMQ
  - name: Apache Spark
    description: Spark Streaming connector for RocketMQ
  - name: Kubernetes
    description: RocketMQ Operator for Kubernetes-native deployment