--- title: Alibaba Cloud RocketMQ description: >- Monitor Alibaba Cloud RocketMQ throughput, message accumulation, consumer lag, and connection metrics. breadcrumbs: Docs > Integrations > Alibaba Cloud RocketMQ --- > For the complete documentation index, see [llms.txt](https://docs.datadoghq.com/llms.txt). # Alibaba Cloud RocketMQ Integration version1.0.0 {% callout %} # Important note for users on the following Datadog sites: us2.ddog-gov.com {% alert level="info" %} To find out if this integration is available in your organization, see your [Datadog Integrations](https://app.datadoghq.com/integrations) page or ask your organization administrator. To initiate an exception request to enable this integration for your organization, email [support@ddog-gov.com](mailto:support@ddog-gov.com). {% /alert %} {% /callout %} ## Overview{% #overview %} Alibaba Cloud Message Queue for Apache RocketMQ is a fully managed, distributed messaging and streaming service used for asynchronous communication, transaction processing, and stream processing at scale. Use this integration to monitor instance throughput, message accumulation, consumer lag, and connection metrics. ## Setup{% #setup %} ### Installation{% #installation %} After you set up the [Alibaba Cloud](https://docs.datadoghq.com/integrations/alibaba_cloud.md) integration, ensure that the RocketMQ service is included in your Alibaba Cloud monitoring configuration. ## Data Collected{% #data-collected %} ### Metrics{% #metrics %} | | | | | **alibabacloud.rocketmq.consumer_lag.sum**(gauge) | Message backlog (Group).*Shown as message* | | **alibabacloud.rocketmq.consumer_lag_latency_per_gid.maximum**(gauge) | Message processing latency (GroupId).*Shown as millisecond* | | **alibabacloud.rocketmq.consumer_lag_latency_per_gid_topic.maximum**(gauge) | Message processing latency (Group, Topic).*Shown as millisecond* | | **alibabacloud.rocketmq.consumer_lag_per_gid_topic.sum**(gauge) | Message backlog (Group, Topic).*Shown as message* | | **alibabacloud.rocketmq.instance_active_connection.average**(gauge) | Number of active connections for public network instances.*Shown as connection* | | **alibabacloud.rocketmq.instance_active_connection.minimum**(gauge) | Number of active connections for public network instances.*Shown as connection* | | **alibabacloud.rocketmq.instance_active_connection.maximum**(gauge) | Number of active connections for public network instances.*Shown as connection* | | **alibabacloud.rocketmq.instance_api_call_tps.sum**(gauge) | Average instance API call TPS.*Shown as transaction* | | **alibabacloud.rocketmq.instance_api_call_tps_max.sum**(gauge) | Peak instance API call TPS.*Shown as transaction* | | **alibabacloud.rocketmq.instance_drop_traffic_rx.average**(rate) | Instance inbound dropped bits per second.*Shown as bit* | | **alibabacloud.rocketmq.instance_drop_traffic_rx.minimum**(rate) | Instance inbound dropped bits per second.*Shown as bit* | | **alibabacloud.rocketmq.instance_drop_traffic_rx.maximum**(rate) | Instance inbound dropped bits per second.*Shown as bit* | | **alibabacloud.rocketmq.instance_drop_traffic_tx.average**(rate) | Instance outbound dropped bits per second.*Shown as bit* | | **alibabacloud.rocketmq.instance_drop_traffic_tx.minimum**(rate) | Instance outbound dropped bits per second.*Shown as bit* | | **alibabacloud.rocketmq.instance_drop_traffic_tx.maximum**(rate) | Instance outbound dropped bits per second.*Shown as bit* | | **alibabacloud.rocketmq.instance_internet_flowout_bandwidth.sum**(rate) | Public network downstream bandwidth for 5.0 series instances.*Shown as bit* | | **alibabacloud.rocketmq.instance_online_clients.sum**(gauge) | Number of online clients.*Shown as connection* | | **alibabacloud.rocketmq.instance_online_clients_utilization.maximum**(gauge) | Online client count utilization.*Shown as percent* | | **alibabacloud.rocketmq.instance_receive_api_call_tps.maximum**(gauge) | Peak consume API call TPS for 5.0 series instances.*Shown as transaction* | | **alibabacloud.rocketmq.instance_receive_tps_utilization.value**(gauge) | Ratio of InstanceReceiveApiCallTps to the lossless elastic consume throttling threshold (or the reserved consume TPS threshold if elasticity is disabled).*Shown as percent* | | **alibabacloud.rocketmq.instance_send_api_call_tps.maximum**(gauge) | Peak send API call TPS for 5.0 series instances.*Shown as transaction* | | **alibabacloud.rocketmq.instance_send_tps_utilization.value**(gauge) | Ratio of InstanceSendApiCallTps to the lossless elastic send throttling threshold (or the reserved send TPS threshold if elasticity is disabled).*Shown as percent* | | **alibabacloud.rocketmq.instance_storage_size.sum**(gauge) | Storage size for 5.0 series instances.*Shown as byte* | | **alibabacloud.rocketmq.instance_tps_utilization.value**(gauge) | Ratio of InstanceApiCallTps to the lossless elastic throttling threshold (or the reserved TPS threshold if elasticity is disabled).*Shown as percent* | | **alibabacloud.rocketmq.instance_traffic_rx.average**(gauge) | Instance inbound bits per second.*Shown as bit* | | **alibabacloud.rocketmq.instance_traffic_rx.minimum**(gauge) | Instance inbound bits per second.*Shown as bit* | | **alibabacloud.rocketmq.instance_traffic_rx.maximum**(gauge) | Instance inbound bits per second.*Shown as bit* | | **alibabacloud.rocketmq.instance_traffic_rx_utilization.average**(gauge) | Instance inbound network bandwidth utilization.*Shown as percent* | | **alibabacloud.rocketmq.instance_traffic_rx_utilization.minimum**(gauge) | Instance inbound network bandwidth utilization.*Shown as percent* | | **alibabacloud.rocketmq.instance_traffic_rx_utilization.maximum**(gauge) | Instance inbound network bandwidth utilization.*Shown as percent* | | **alibabacloud.rocketmq.instance_traffic_tx.average**(gauge) | Instance outbound bits per second.*Shown as bit* | | **alibabacloud.rocketmq.instance_traffic_tx.minimum**(gauge) | Instance outbound bits per second.*Shown as bit* | | **alibabacloud.rocketmq.instance_traffic_tx.maximum**(gauge) | Instance outbound bits per second.*Shown as bit* | | **alibabacloud.rocketmq.instance_traffic_tx_utilization.average**(gauge) | Instance outbound network bandwidth utilization.*Shown as percent* | | **alibabacloud.rocketmq.instance_traffic_tx_utilization.minimum**(gauge) | Instance outbound network bandwidth utilization.*Shown as percent* | | **alibabacloud.rocketmq.instance_traffic_tx_utilization.maximum**(gauge) | Instance outbound network bandwidth utilization.*Shown as percent* | | **alibabacloud.rocketmq.ready_message_queue_time.maximum**(gauge) | Ready message queuing time (Group).*Shown as millisecond* | | **alibabacloud.rocketmq.ready_message_queue_time_per_gid_topic.maximum**(gauge) | Ready message queuing time (Group, Topic).*Shown as millisecond* | | **alibabacloud.rocketmq.ready_messages.sum**(gauge) | Ready message count (Group).*Shown as message* | | **alibabacloud.rocketmq.ready_messages_per_gid_topic.sum**(gauge) | Ready message count (Group, Topic).*Shown as message* | | **alibabacloud.rocketmq.receive_message_count_per_gid.sum**(rate) | Messages received by consumer per minute (Group).*Shown as message* | | **alibabacloud.rocketmq.receive_message_count_per_gid_topic.sum**(rate) | Messages received by consumer per minute (Group, Topic).*Shown as message* | | **alibabacloud.rocketmq.receive_message_count_per_instance.sum**(rate) | Messages received by consumer per minute (Instance).*Shown as message* | | **alibabacloud.rocketmq.receive_message_count_per_topic.sum**(rate) | Messages received by consumer per minute (Topic).*Shown as message* | | **alibabacloud.rocketmq.send_dlq_message_count_per_gid.sum**(rate) | Dead-letter messages produced per minute (Group).*Shown as message* | | **alibabacloud.rocketmq.send_dlq_message_count_per_gid_topic.sum**(rate) | Dead-letter messages produced per minute (Group, Topic).*Shown as message* | | **alibabacloud.rocketmq.send_message_count_per_instance.sum**(rate) | Messages sent by producer per minute (Instance).*Shown as message* | | **alibabacloud.rocketmq.send_message_count_per_topic.sum**(rate) | Messages sent by producer per minute (Topic).*Shown as message* | | **alibabacloud.rocketmq.sink_cluster_average_process_time_per_task.value**(gauge) | Average message processing response time on the sink cluster (Task).*Shown as millisecond* | | **alibabacloud.rocketmq.sink_cluster_average_process_time_per_topic.value**(gauge) | Average message processing response time on the sink cluster (Task & Topic).*Shown as millisecond* | | **alibabacloud.rocketmq.sink_cluster_messages_in_per_task.maximum**(rate) | Message inflow rate on the sink cluster (Task).*Shown as message* | | **alibabacloud.rocketmq.sink_cluster_messages_in_per_topic.maximum**(rate) | Message inflow rate on the sink cluster (Task & Topic).*Shown as message* | | **alibabacloud.rocketmq.source_cluster_consumer_lag_latency_per_task.maximum**(gauge) | Message processing latency on the source cluster (Task).*Shown as millisecond* | | **alibabacloud.rocketmq.source_cluster_consumer_lag_latency_per_topic.maximum**(gauge) | Message processing latency on the source cluster (Task & Topic).*Shown as millisecond* | | **alibabacloud.rocketmq.source_cluster_consumer_lag_per_task.maximum**(gauge) | Message backlog on the source cluster (Task).*Shown as message* | | **alibabacloud.rocketmq.source_cluster_consumer_lag_per_topic.maximum**(gauge) | Message backlog on the source cluster (Task & Topic).*Shown as message* | | **alibabacloud.rocketmq.source_cluster_messages_out_per_task.maximum**(rate) | Message outflow rate on the source cluster (Task).*Shown as message* | | **alibabacloud.rocketmq.source_cluster_messages_out_per_topic.maximum**(rate) | Message outflow rate on the source cluster (Task & Topic).*Shown as message* | | **alibabacloud.rocketmq.throttled_receive_requests_per_gid.sum**(rate) | Number of times consumption was throttled per minute (GroupId).*Shown as request* | | **alibabacloud.rocketmq.throttled_receive_requests_per_gid_topic.sum**(rate) | Number of times consumption was throttled per minute (Group, Topic).*Shown as request* | | **alibabacloud.rocketmq.throttled_receive_requests_per_instance.sum**(rate) | Number of times consumption was throttled per minute (Instance).*Shown as request* | | **alibabacloud.rocketmq.throttled_send_requests_per_instance.sum**(rate) | Number of times sending was throttled per minute (Instance).*Shown as request* | | **alibabacloud.rocketmq.throttled_send_requests_per_topic.sum**(rate) | Number of times sending was throttled per minute (Topic).*Shown as request* | ### Events{% #events %} Alibaba Cloud RocketMQ does not include any events. ### Service Checks{% #service-checks %} Alibaba Cloud RocketMQ does not include any service checks. ## Troubleshooting{% #troubleshooting %} Need help? Contact [Datadog support](https://docs.datadoghq.com/help/).