Monitor consumer group health by checking connection status, subscription consistency, message accumulation metrics, and client information in the ApsaraMQ for RocketMQ console. Use these details to identify slow, stuck, or disconnected consumers and take remedial actions -- such as scaling consumers or fixing subscription mismatches -- before message accumulation impacts your application.
Common troubleshooting scenarios
Scenario | Symptoms | Action |
Inconsistent subscriptions | The Subscriptions section on the Group Details page displays: Subscriptions are inconsistent. Fix the issue promptly. | |
Message accumulation | Inflight Messages, Ready Messages, or Queuing Time values are higher than expected on the Group Details page. |
View basic consumer group information
Prerequisites
An ApsaraMQ for RocketMQ instance with at least one consumer group.
Procedure
Log on to the ApsaraMQ for RocketMQ console. In the left-side navigation pane, click Instances.
In the top navigation bar, select a region, such as China (Hangzhou). On the Instances page, click the name of the instance that you want to manage.
In the left-side navigation pane, click Groups. On the page that appears, click the name of the consumer group that you want to inspect.
Results
The Group Details page displays the following fields.
Field | Description |
Consumer Status | Online: At least one consumer in the group is connected to the broker. Connected consumer details appear in the Client Connection Information section. Offline: No consumers are connected. The Client Connection Information section is empty. |
Consumption Mode | The subscription mode used by consumers in the group: clustering (default) or broadcasting. You modify the consumption mode on the client side. For details, see Clustering consumption and broadcasting consumption. |
Real-time Consumption Rate | Total transactions per second (TPS) used by all consumers in the group to receive messages. |
Inflight Messages | Messages that consumers are processing and have not yet returned consumption results for. |
Ready Messages | Messages on the ApsaraMQ for RocketMQ broker that are visible to consumers and available for consumption. |
Queuing Time | Time elapsed since the earliest ready message became available. A high value indicates consumers are falling behind. |
Subscriptions | Subscription consistency status and the tags each consumer subscribes to. Only connected clients are shown. For details, see Subscription consistency. |
Client Connection Information | IP address, client version, and stack details for each connected consumer. |
View message accumulation metrics
Procedure
On the Groups page, click Dashboard.
The dashboard also provides instance-level metrics. For details, see Dashboard.
Results
The dashboard displays consumption metrics for the consumer group, including message accumulation volume, consumption rate, and trend charts for production and consumption rates per topic.
Troubleshoot a consumption exception
If consumers are not keeping up with message production, follow these steps to narrow down the cause:
In the consumption scenario indicators panel, identify the topic with the highest message accumulation.
Select that topic from the Topic drop-down list at the top of the page.
Review the trend charts for message accumulation volume and production/consumption rates to pinpoint when the issue started.
Determine whether any backend operations were performed or network exceptions occurred during that time window.
API reference
Query consumer group details and message accumulation programmatically with the following API operations:
OnsConsumerAccumulate: Retrieve message accumulation details for a consumer group.
OnsConsumerStatus: Retrieve consumer status and connection information.