ApsaraMQ for RocketMQ:Features

Feature set

Feature

Description

Documentation

Instance management

Instance list query

Query a list of instances in a specified region, including instance name, version, type, status, and topic count.

Instance details

View instance details, endpoints, and resource quotas; query messages and peak TPS.

Instance creation

Create an instance as an isolated service environment to receive, store, and forward messages.

Instance modification

Edit instance descriptions, publish/consume ratios, and message retention periods.

Instance release

Release selected instances via the console. Note that this action is irreversible. Pay-as-you-go and Serverless instances support direct release, whereas subscription instances must be released through the unsubscription process.

Feature set

Feature

Description

Documentation

Topic management

Topic list query

View the list of topics within an instance, including topic name, type, status, and creation time.

Topic details

View the topic name, type, description, status, creation time, last write time, and associated consumer groups.

Topic creation

Create topics for message production and consumption, including normal, ordered, scheduled, and transactional messages.

Topic modification

Modify the description of a selected topic.

Quick start

Perform a quick verification of message production, consumption, accumulation, and retries for a selected topic.

Topic deletion

Delete selected topics via the console. Note that deletion takes effect immediately, rendering the topics unavailable.

Topic import

Import topic configurations in bulk using a predefined template.

Topic export

Export topic configurations in bulk using a predefined template.

Topic dashboard

Monitor message volume and accumulation for a selected topic.

Feature set

Feature

Description

Documentation

Group management

Group creation

Create consumer groups to subscribe to topics within an instance. (Support for both concurrent and sequential delivery modes; configurable retry policies and maximum retry times; dead-letter message redirection to specified topics.)

Group list query

View all active consumer groups within an instance, including group ID, status, and creation time.

Group details

View group details, including group ID, status, creation time, description, delivery mode, dead-letter policy, and subscription relationships.

Running information query

Monitor group running data, including consumption progress and client connection status.

Group dashboard

View group metrics, including message accumulation, production/consumption rates, latency, and success rates.

Group modification

Update group configurations such as delivery mode, description, retry policy, and dead-letter policy.

Group export

Export group configurations in bulk using a predefined template.

Group import

Import group configurations in bulk using a predefined template.

Group deletion

Delete selected consumer groups with immediate effect.

Consumer offset reset

Reset consumer offsets to the latest or a specific timestamp.

Feature set

Feature

Description

Documentation

Subscription instance billing

Messaging fee

Charges are calculated based on the selected specification and peak TPS limit, and are billed monthly.

Storage fee

Charges are based on the storage capacity used and the storage duration, and are calculated and deducted hourly based on usage in the previous hour.

Internet access fee

Charges are based on bandwidth and apply only to outbound (downstream) bandwidth.

Elastic TPS fee

Provide burstable capacity for sporadic traffic spikes without requiring reserved buffer. Charges for burst traffic are billed on a pay-as-you-go basis.

Pay-as-you-go instance billing

Messaging fee

Charges are calculated based on the selected specification and peak TPS limit, and are billed hourly.

Storage fee

Charges are based on the storage capacity used and the storage duration, and are calculated and deducted hourly based on usage in the previous hour.

Internet access fee

Charges are based on bandwidth and apply only to outbound (downstream) bandwidth.

Elastic TPS fee

Provide burstable capacity for sporadic traffic spikes without requiring reserved buffer. Charges for burst traffic are billed on a pay-as-you-go basis.

Upgrade/Downgrade for subscription and pay-as-you-go instances

Instance configuration change

Upgrade configurations (peak TPS, storage, bandwidth) to handle business growth or traffic surges. Downgrade configurations during low-activity periods to optimize costs.

Billing method conversion

Conversion from pay-as-you-go to subscription

Convert instances to the subscription model for stable, long-term workloads to ensure resource availability and benefit from discounted rates.

Standard Edition billing

Messaging pricing

Charge for message production and consumption based on API call volume. Tiered pricing applies based on monthly usage and region.

Internet traffic pricing

Charge for data transfer when accessing services via public endpoints.

Topic resource fee

Apply a daily resource fee per topic. Unit prices are tiered based on the daily message volume of each topic.

Resource plans

Purchase resource plans for API requests and topics to reduce costs compared to standard pay-as-you-go rates. Usage is deducted from resource plans first; any excess usage is billed at standard pay-as-you-go rates.

-

Global message routing pricing

Charge for global message routing as an advanced feature on a pay-as-you-go basis. No charges apply if the feature is not used. Advanced features must be used in conjunction with basic messaging capabilities. Message transfer fee = Message volume × Unit price. Topic resource Fee = Topic count × Unit price.

-

Enterprise Platinum Edition Billing

Enterprise Platinum Edition

Enterprise Platinum Edition instances are billed on a subscription basis and are suitable for scenarios that require high SLAs or involve large message volumes. Subscription billing enables resource reservation and offers greater discounts. Compared with Standard Edition instances, Enterprise Platinum Edition instances provide higher availability and support additional advanced features, such as attribute-based SQL filtering and pull consumers.

Feature set

Feature

Description

Documentation

Dashboard

Dashboard

Deliver metric data to a user-owned Prometheus instance and visualize it via Grafana dashboards.

Feature set

Feature

Description

Documentation

IP allowlist

IP allowlisting

Add CIDR blocks or static IP addresses to an allowlist. Only clients within the allowlist can access ApsaraMQ for RocketMQ.

Allowlisted IP address deletion

Remove IP addresses from the allowlist to revoke access for associated clients.

Intelligent authentication

Intelligent authentication

Access ApsaraMQ for RocketMQ using system-initialized credentials.

Credential-free access within a VPC

The server authenticates requests based on the client's VPC network context.

ACL user management

Manage ACL credentials for authentication. Create, delete, update, and query ACL users. Temporarily disable or re-enable users as needed.

ACL permissions

Manage authorization for RocketMQ resources. Grant or revoke permissions for specific users.

RAM-based control

RAM-based API control

Control access to the console and management APIs using RAM policies.

RAM-based resource control

Ensure account and resource security using RAM policies.

Feature set

Feature

Description

Documentation

Message tracing

Query by message ID

Trace messages by message ID.

Query by message key

Trace messages by message key.

Query by topic

Trace messages by topic.

Message tracing

View producer details including hostname, send time, server arrival time, and result. View consumer details including node info and reception time.

Trace diagram generation

Generate a trace diagram for queried message traces.

Feature set

Feature

Description

Documentation

Monitoring and alerting

Metric query

Query metrics at the instance, group, topic, and group/topic levels, including API call frequency, messages sent/received per minute, and production/consumption throttling events.

Alert rule creation

Configure alert rules in Cloud Monitor based on specific metrics, thresholds, and severity levels. Notify designated contact groups.

Feature set

Feature

Description

Documentation

Message query

Query by message ID

Retrieve message content, system attributes, and custom attributes by message ID.

Query by message key

Retrieve message content, system attributes, and custom attributes by message key.

Consumption verification

Resend queried messages to verify consumption logic.

Message download

Download queried message data based on a template.

Feature set

Feature

Description

Documentation

Cloud migration

Migration task creation

Configure seamless migration from open-source RocketMQ to ApsaraMQ for RocketMQ 5.0 instances.

Task details

View network configurations and metadata for migration tasks.

• Configure network settings
• Migrate metadata

Self-service troubleshooting

Anomaly diagnosis

Analyze logs to identify anomalies, run backend diagnostics for instances, and generate actionable remediation recommendations.

Feature set

Feature

Description

Documentation

Backup task configuration

Unidirectional backup

Configure one-way data synchronization tasks between ApsaraMQ for RocketMQ instances and self-managed open-source RocketMQ clusters, or between ApsaraMQ for RocketMQ instances.

• Data aggregation (unidirectional backup)
• Active-passive geo-redundancy

Bidirectional backup

Configure two-way data synchronization tasks between ApsaraMQ for RocketMQ instances and self-managed open-source RocketMQ clusters, or between ApsaraMQ for RocketMQ instances.

Backup monitoring

Metric monitoring

Track synchronization metrics, including total data volume, ingestion/egress rates, and accumulation.

Alerting

Configure Cloud Monitor alerts to notify recipients when synchronization metrics exceed defined thresholds.

Feature set

Feature

Description

Documentation

Integration overview

Message inflow

View supported Alibaba Cloud services for ingesting data into ApsaraMQ for RocketMQ.

Message outflow

View supported Alibaba Cloud services for streaming data out of ApsaraMQ for RocketMQ.

Task creation

Quickly create synchronization tasks by selecting supported sources and sinks.

Task list

Task list

View all integration tasks, including name, source, destination, and status.

Task creation

Sync data to ApsaraMQ for RocketMQ from sources including ApsaraMQ for Kafka, ApsaraMQ for RabbitMQ, Simple Message Queue (SMQ) (formerly MNS), ApsaraMQ for MQTT, and Data Transmission Service (DTS). Sync RocketMQ data to targets including Kafka, RabbitMQ, SMQ, MQTT, and Function Compute.

• Create a message inflow task
• Create a message outflow task

Message transformation

Transform data during synchronization. Support full/partial event mapping, constant values, and templates.

Message filtering

Filter data using matching modes such as exact match, prefix, suffix, exclude, numeric values/ranges, IP address match, multi-pattern match, array match, null-value match, and existence match.

Retry and dead-lettering

Configure retry and dead-letter policies for synchronization tasks to improve fault tolerance.

Task deletion

Delete selected tasks with immediate effect.

Task suspension

Suspend running tasks to temporarily stop data synchronization.

Task resumption

Resume suspended tasks and continue synchronization from the point of interruption.

Task modification

Modify filtering and transformation strategies for existing tasks.

Feature set

Feature

Description

Documentation

Disaster recovery and backup

RocketMQ Replicator

Provide cross-region and cross-instance synchronization for messages and consumer offsets. Support data synchronization between open-source RocketMQ clusters and ApsaraMQ for RocketMQ instances, and meet requirements for active-passive geo-redundancy and active-active geo-redundancy deployments.

-