All Products
Search
Document Center

ApsaraMQ for RocketMQ:Configure the monitoring and alerting feature for risk warning

Last Updated:Feb 07, 2024

ApsaraMQ for RocketMQ allows you to configure alert rules by using CloudMonitor. This helps you monitor the status and key metrics of your instance in real time and enables you to receive exception notifications at the earliest opportunity to implement risk warnings in production environments.

Background information

ApsaraMQ for RocketMQ provides fully managed messaging services and a Service Level Agreement (SLA) for each instance edition. After you purchase an ApsaraMQ for RocketMQ instance, the capabilities of the instance, such as the messaging transactions per second (TPS) and message storage capabilities, are guaranteed.

You do not need to worry about the instance performance. However, you must monitor your instance usage in production environments to make sure that you do not exceed the thresholds that are specified for your instance. ApsaraMQ for RocketMQ integrates with CloudMonitor to provide monitoring and alerting services free of charge and for immediate use. You can use the services to monitor the following items:

  • Instance usage

    If your actual instance usage exceeds the specification limit, ApsaraMQ for RocketMQ forcibly throttles the instance. To prevent faults that are caused by instance throttling, you can configure the instance usage alert in advance and upgrade your instance configurations when an excess usage risk is detected.

  • Business logic errors

    Errors may occur when you send and receive messages. You can configure the invocation error alert to detect and fix errors and prevent negative impacts on your business.

  • Performance metrics

    If performance metrics such as response time (RT) and message delay are required for your message system, you can configure the corresponding metric alerts in advance to prevent business risks.

Rules for configuring alerts

ApsaraMQ for RocketMQ provides various metrics and monitoring and alerting items. For more information, see Dashboard and Monitoring and alerting. Monitoring items can be divided into the following categories: resource usage, messaging performance, and messaging exceptions.

Based on accumulated best practices in production environments, we recommend that you follow the rules that are described in the following table to configure alerts.

Note

The following monitoring items are basic configurations that are recommended by Alibaba Cloud. ApsaraMQ for RocketMQ also provides other monitoring items. You can configure fine-grained alerts based on your business requirements. For more information, see Monitoring and alerting.

Category

Monitoring item

Configuration timing and reason

Related personnel

Resource usage

API calls on an instance

  • We recommend that you configure this item immediately after an instance is created.

  • The resource usage of an instance is not determined by one topic or group. You must consider the overall resource usage of the instance.

Resource operators

Messaging performance

  • Message sending TPS in a topic

  • Message receiving TPS in a consumer group

  • Message accumulation in a consumer group

  • Consumption delay time in a consumer group

  • We recommend that you configure these items immediately after your business is launched.

  • After your business is launched, you must estimate the messaging performance of your business.

  • Resource operators

  • Business developers

Messaging errors

  • Generation of dead-letter messages

  • Number of times that throttling occurs

  • We recommend that you configure these items immediately after your business is launched.

  • After your business is launched, you must predict failures that may occur during message production. This helps you troubleshoot issues.

  • Resource operators

  • Business developers

Best practices for configuring the alert about the number of API calls on an instance

  • Background: In ApsaraMQ for RocketMQ, the number of API calls that you can initiate to send and receive messages on an instance is measured by messaging TPS. A peak messaging TPS is specified for each instance. If the messaging TPS on your instance exceeds the specification limit, the instance is throttled. For example, a peak TPS of 5,000 is specified for a Standard Edition instance. If the limit is exceeded, the instance is throttled.

  • Risk caused by not configuring the alert: If you do not configure the alert, you cannot receive alerts before the number of API calls exceeds the specification limit. As a result, your instance is throttled and specific messages fail to be sent or received.

  • Configuration timing: We recommend that you configure the alert after the instance is created.

  • Recommended threshold: We recommend that you set the alert threshold to 70% of the specification limit. For example, if the peak messaging TPS of the instance that you purchased is 10,000, set the alert threshold to 7,000.

  • Alert handling: After you receive an alert about the number of API calls, we recommend that you perform the following steps to handle the alert:

    1. Go to the Dashboard page in the ApsaraMQ for RocketMQ console, view the change trend of the traffic that is used to send messages, and then check whether the business changes are normal.

    2. If the business changes are abnormal, contact your users for further analysis.

    3. If the business changes are normal, the computing specification of your instance is insufficient to maintain normal business operations. In this case, we recommend that you upgrade your instance configurations. For more information, see Upgrade or downgrade instance configurations.

image.png

Best practices for configuring the alert about message sending TPS in a topic or message receiving in a consumer group

  • Background: ApsaraMQ for RocketMQ provides metrics to monitor messaging TPS by topic and consumer group. You can use the metrics to monitor messaging TPS in a specific business item and understand your business scale.

  • Risks caused by not configuring the alert: Messaging TPS in a topic specifies the number of API calls that you can initiate to send and receive messages in the topic. If you do not configure the alert, you cannot receive alerts before traffic drops to zero or traffic spikes occur. This may cause unexpected risks.

  • Configuration timing: We recommend that you configure the alert after your business stabilizes.

  • Recommended threshold: We recommend that you configure the threshold based on the traffic volume after your business stabilizes.

  • Alert handling: After you receive an alert about messaging TPS, we recommend that you perform the following steps to handle the alert:

    1. Go to the Dashboard page in the ApsaraMQ for RocketMQ console, view the messaging TPS curve of the specified topic or group, and then check whether the traffic changes are normal.

    2. Determine whether the traffic changes are normal based on the business model.

image.png

Best practices for configuring the message accumulation alert

Note

Fluctuation and errors may exist in the statistics about message accumulation. We recommend that you do not set the threshold for accumulated messages to less than 100. If your business is affected even if the number of accumulated messages is small, we recommend that you configure the consumption delay time alert to monitor message accumulation.

  • Background: ApsaraMQ for RocketMQ allows you to monitor message accumulation by consumer group. You can use the message accumulation alert to prevent faults that are caused by message accumulation.

  • Risks caused by not configuring the alert: Message accumulation is a typical scenario and capability of ApsaraMQ for RocketMQ. In scenarios in which messages must be processed in real time, you must monitor and manage the number of accumulated messages to prevent negative impacts caused by message accumulation on your business.

  • Configuration timing: We recommend that you configure the alert after your business stabilizes.

  • Recommended threshold: We recommend that you configure the threshold based on the actual performance of your business.

  • Alert handling: After you receive an alert about message accumulation, we recommend that you perform the following steps to handle the alert:

    1. Go to the Dashboard page in the ApsaraMQ for RocketMQ console, view the change trend of the message accumulation curve of the specified consumer group, and then find the time when message accumulation started.

    2. Analyze the cause of message accumulation based on business changes and application logs. For more information, see How can I handle accumulated messages?

    3. Determine whether to scale out the consumer application or fix the consumption logic defect based on the cause of message accumulation.

image.png

Best practices for configuring the consumption delay time alert

Note

Consumption delay time is calculated based on the delay time of the first unconsumed message in a consumer group. Consumption delay time is cumulative and sensitive to business changes. After you receive an alert about consumption delay time, you must determine whether a small number of messages or all messages are delayed.

  • Background: ApsaraMQ for RocketMQ allows you to monitor consumption delay by consumer group. The consumption delay time alert provides a detailed metric for analyzing message accumulation.

  • Risks caused by not configuring the alert: Message accumulation is a typical scenario and capability of ApsaraMQ for RocketMQ. In scenarios in which messages must be processed in real time, you must monitor and manage the number of accumulated messages and the consumption delay time to prevent negative impacts caused by message accumulation on your business.

  • Configuration timing: We recommend that you configure the alert after your business stabilizes.

  • Recommended threshold: We recommend that you configure the threshold based on the actual performance of your business.

  • Alert handling: After you receive an alert about consumption delay time, we recommend that you perform the following steps to handle the alert:

    1. Go to the Dashboard page in the ApsaraMQ for RocketMQ console, view the change trend of the message accumulation curve of the specified group, and then find the time when message accumulation started.

    2. Analyze the cause of message accumulation based on business changes and application logs. For more information, see How can I handle accumulated messages?

    3. Determine whether to scale out the consumer application or fix the consumption logic defect based on the cause of message accumulation.

image.png

Best practices for configuring the dead-letter message alert

  • Background: ApsaraMQ for RocketMQ supports dead-letter messages. Messages that fail to be consumed after the specified maximum number of retries is reached are sent to dead-letter queues. You can manage dead-letter messages. You can monitor the number of dead-letter messages to help you detect unexpected issues and exceptions in your business.

  • Risks caused by not configuring the alert: Dead-letter messages are messages that cannot be correctly processed by consumers. Consumption applications must handle dead-letter messages. If you do not configure the dead-letter message alert, message consumption may be incomplete.

  • Configuration timing: We recommend that you configure the alert after your business stabilizes.

  • Recommended threshold: We recommend that you configure the threshold based on the traffic volume after your business stabilizes.

  • Alert handling: After you receive an alert about dead-letter messages, we recommend that you perform the following steps to handle the alert:

    1. Query dead-letter messages and analyze the original messages. For more information, see Dead-letter queues.

    2. Query the consumption traces of the messages and analyze the cause of consumption failure based on the topics and message IDs. For more information, see Query message traces.

    3. Determine the appropriate solution based on the cause of message consumption failure.

image.png

Best practices for configuring the alert about the number of times that throttling occurs

  • Background: ApsaraMQ for RocketMQ allows you to use events that trigger throttling on a specific instance as alert metrics. This helps you understand negative impacts on your business.

  • Risks caused by not configuring the alert: A large number of times that throttling occurs indicates that your traffic usage frequently exceeds the specification limit. In this case, we recommend that you upgrade your instance configurations.

  • Configuration timing: We recommend that you configure the alert after your business stabilizes.

    • We recommend that you configure the alert about the number of times that throttling occurs on an instance after the instance is created.

    • We recommend that you configure the alert about the number of times that throttling occurs in a topic or consumer group after your business stabilizes.

  • Recommended threshold: We recommend that you configure the threshold based on the actual performance of your business.

  • Alert handling: After you receive an alert about the number of times that throttling occurs, we recommend that you perform the following steps to handle the alert:

    1. Go to the Dashboard page in the ApsaraMQ for RocketMQ console, view the messaging TPS curve of the specified instance, topic, or consumer group, and then analyze the time when throttling occurred and the throttling pattern.

    2. Based on the statistics on the dashboard, check the topics or consumer groups that use the most TPS to determine whether the traffic increase meets your business requirements.

    3. If the traffic increase meets your business requirements, upgrade your instance configurations. Otherwise, troubleshoot the issue.

image.png