消息队列 Pulsar 版监控指标

最近更新时间:2026-03-06 14:18:32

我的收藏

命名空间

Namespace = QCE/TDMQ

监控指标

指标英文名
指标中文名
说明
单位
维度
统计规则
[period, statType]
PulsarTenantTps
pulsar 集群 tps
pulsar 集群 tps
Count/s
tenant
[ 60s, expr ]
[ 300s, avg ]
TenantTotalTps
每秒峰值总速率
每秒峰值总速率
Count/s
tenant
[ 60s, expr ]
[ 300s, max ]
[ 3600s, max ]
[ 86400s, max ]
PulsarTenantTpsUsage
pulsar 集群 tps 使用率
当前集群 TPS 已使用百分比,单位时间取最大值
%
tenant
[ 60s, expr ]
[ 300s, avg ]
TenantTpsUsageMax
pulsar 集群 tps 使用率峰值
pulsar 集群 tps 使用率峰值
%
tenant
[ 60s, expr ]
[ 300s, max ]
[ 3600s, max ]
[ 86400s, max ]
TenantCaculateRateIn
消息生产速率
当前集群的消息生产速率
Count/s
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantCaculateRateOut
消息消费速率
当前集群的消息消费速率
Count/s
tenant
[ 60s, sum ]
[ 300s, avg ]
PulsarTenantThroughputIn
pulsar 集群生产带宽峰值
pulsar 集群生产带宽峰值
Bytes/s
tenant
[ 60s, sum ]
[ 300s, avg ]
PulsarTenantThroughputOut
pulsar 集群消费带宽峰值
pulsar 集群消费带宽峰值
Bytes/s
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantTagFilterRejectedMsgRate
标签过滤消息速率
标签过滤消息速率
Count/s
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantTagFilterRejectedBytesRate
标签过滤消息流量
标签过滤消息流量
Bytes/s
tenant
[ 60s, sum ]
[ 300s, avg ]
PulsarMessageDelayed
延迟消息消息量
使用了 TDMQ 延迟消息功能的消息数量,这种消息在生产后不会马上被消费,用户会指定一个延迟时间,过后才允许消费者消费
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantDelayRateIn
延迟消息发送速率
当前维度的延迟消息发送速率
Count/s
tenant
[ 60s, sum ]
[ 300s, avg ]
[ 3600s, avg ]
[ 86400s, avg ]
PulsarMessageDelayedUsage
Pulsar 集群延迟消息使用占比
当前集群延迟消息已使用百分比,单位时间取最大值
%
tenant
[ 60s, expr ]
[ 300s, avg ]
TenantClbInTraffic
公网入口流量
公网入口流量
Mbps
tenant
[ 60s, max ]
[ 300s, max ]
TenantClbOutTraffic
公网出口流量
公网出口流量
Mbps
tenant
[ 60s, max ]
[ 300s, max ]
PulsarClbIntrafficVipRatio
公网入带宽占比
公网入带宽占比,公网入口流量占公网带宽百分比
%
tenant
[ 60s, expr ]
[ 300s, max ]
PulsarClbOuttrafficVipRatio
公网出带宽占比
公网出带宽占比,公网出口流量占公网带宽百分比
%
tenant
[ 60s, expr ]
[ 300s, max ]
PulsarDiskUsedMib
磁盘使用量
专业版集群磁盘使用量
MiBytes
tenant
[ 60s, max ]
[ 300s, avg ]
[ 3600s, avg ]
[ 86400s, avg ]
TenantStorageSize
租户级别消息积压大小
租户级别消息积压大小
Bytes
tenant
[ 60s, sum ]
[ 300s, avg ]
PulsarDiskUsage
磁盘使用率
专业版集群的磁盘使用率
%
tenant
[ 60s, expr ]
[ 300s, max ]
[ 3600s, max ]
[ 86400s, max ]
TenantStorageSizeUsedPercentage
存储大小已使用百分比
当前集群存储大小已使用百分比
%
tenant
[ 60s, expr ]
[ 300s, avg ]
[ 3600s, avg ]
[ 86400s, avg ]
TenantInLimitCount
每分钟租户限流写入请求受限次数
每分钟租户限流写入请求受限次数
Count
tenant
[ 60s, avg ]
[ 300s, avg ]
TenantOutLimitCount
每分钟租户限流消费请求受限次数
每分钟租户限流消费请求受限次数
Count
tenant
[ 60s, avg ]
[ 300s, avg ]
TenantTopicUsedPercentage
主题数量已使用占比
主题数量已使用占比
%
tenant
[ 60s, expr ]
[ 300s, max ]
[ 3600s, max ]
[ 86400s, max ]
TenantTopicPartitionUsedPercentage
主题分区数量已使用占比
主题分区数量已使用占比
%
tenant
[ 60s, expr ]
[ 300s, max ]
[ 3600s, max ]
[ 86400s, max ]
TenantTopicsUsedCount
主题已使用数量
当前集群主题已使用数量
Count
tenant
[ 60s, max ]
[ 300s, max ]
[ 3600s, max ]
[ 86400s, max ]
TenantTopicsPartitionedUsedCount
主题分区已使用数量
当前集群主题分区已使用数量
Count
tenant
[ 60s, max ]
[ 300s, max ]
[ 3600s, max ]
[ 86400s, max ]
NsCaculateRateIn
消息生产速率
当前命名空间下消息生产速率
Count/s
environmentId
tenantId
[ 60s, sum ]
[ 300s, avg ]
[ 3600s, avg ]
[ 86400s, avg ]
NsCaculateRateOut
消息消费速率
当前命名空间下消息消费速率
Count/s
environmentId
tenantId
[ 60s, sum ]
[ 300s, avg ]
[ 3600s, avg ]
[ 86400s, avg ]
NsThroughputIn
消息生产流量
当前命名空间下消息生产流量
Bytes/s
environmentId
tenantId
[ 60s, sum ]
[ 300s, avg ]
NsThroughputOut
消息消费流量
当前命名空间下消息消费流量
Bytes/s
environmentId
tenantId
[ 60s, sum ]
[ 300s, avg ]
NsStorageSize
命名空间消息积压大小
命名空间消息积压大小
Bytes
environmentId
tenantId
[ 60s, sum ]
[ 300s, avg ]
PulsarCaculateRateIn
消息生产速率
当前主题的消息生产速率
Count/s
environmentId
tenantId
topicName
[ 60s, sum ]
[ 300s, avg ]
[ 3600s, avg ]
[ 86400s, avg ]
PulsarCaculateRateOut
消息消费速率
当前主题的消息消费速率
Count/s
environmentId
tenantId
topicName
[ 60s, sum ]
[ 300s, avg ]
[ 3600s, avg ]
[ 86400s, avg ]
TopicTagFilterRejectedMsgRate
标签过滤消息速率
当前主题的标签过滤消息速率
Count/s
environmentId
tenantId
topicName
[ 60s, sum ]
[ 300s, avg ]
MsgThroughputIn
消息生产流量
消息生产流量
Bytes/s
environmentId
tenantId
topicName
[ 60s, sum ]
[ 300s, avg ]
[ 3600s, avg ]
[ 86400s, avg ]
MsgThroughputOut
消息消费流量
在所选时间范围内某一秒,本 Topic 下所有消费者消费的消息数据量大小
Bytes/s
environmentId
tenantId
topicName
[ 60s, sum ]
[ 300s, avg ]
[ 3600s, avg ]
[ 86400s, avg ]
TopicTagFilterRejectedBytesRate
标签过滤消息流量
标签过滤消息流量
Bytes/s
tenantId
topicName
environmentId
[ 60s, sum ]
[ 300s, avg ]
TopicMessageDelayed
延迟消息消息量
使用了 TDMQ 延迟消息功能的消息数量,这种消息在生产后不会马上被消费,用户会指定一个延迟时间,过后才允许消费者消费
Count
tenantId
topicName
environmentId
[ 60s, sum ]
[ 300s, avg ]
StorageSize
积压消息大小
Topic下消息的存储大小(包括持久化消息和 UNACK 消息),消息过期或消费即删除后,该指标会下降
Bytes
environmentId
tenantId
topicName
[ 60s, sum ]
[ 300s, avg ]
[ 3600s, avg ]
[ 86400s, avg ]
TopicDelayRateIn
延迟消息发送速率
当前维度的延迟消息发送速率
Count/s
environmentId
tenantId
topicName
[ 60s, sum ]
[ 300s, avg ]
[ 3600s, avg ]
[ 86400s, avg ]
ProducersCount
生产者数量
生产者数量
Count
topicName
environmentId
tenantId
[ 60s, last ]
[ 300s, avg ]
[ 3600s, avg ]
[ 86400s, avg ]
ConsumersCount
消费者数量
消费者数量
Count
environmentId
tenantId
topicName
[ 60s, sum ]
[ 300s, sum ]
[ 3600s, sum ]
[ 86400s, sum ]
TopicProducerPercentage
生产者已使用占比
当前 Topic 下生产者数量已使用百分比,单位时间取最大值
%
tenantId
topicName
environmentId
[ 60s, max ]
[ 300s, avg ]
[ 3600s, avg ]
[ 86400s, avg ]
TopicConsumerPercentage
消费者已使用占比
当前 Topic 下消费者数量已使用百分比,单位时间取最大值
%
environmentId
tenantId
topicName
[ 60s, max ]
[ 300s, avg ]
[ 3600s, avg ]
[ 86400s, avg ]
TopicExceedMaxTimeDelayMessage
延迟消息时间超最大时间规格数量
延迟消息时间超最大时间规格数量
Count
tenantId
topicName
environmentId
[ 60s, sum ]
[ 300s, max ]
[ 3600s, max ]
[ 86400s, max ]
TopicExceedTtlDelayMessage
延迟消息时间超 TTL 数量
延迟消息时间超 TTL 数量
Count
environmentId
tenantId
topicName
[ 60s, sum ]
[ 300s, max ]
[ 3600s, max ]
[ 86400s, max ]
SubMsgCaculateRateOut
消息消费速率
当前订阅的消息消费速率
Count/s
topicName
environmentId
subName
tenantId
[ 60s, sum ]
[ 300s, avg ]
[ 3600s, avg ]
[ 86400s, avg ]
PulsarSubscriptionTagFilterRejectedMsgRate
标签过滤消息速率
标签过滤消息速率
Count/s
subName
tenantId
topicName
environmentId
[ 60s, sum ]
[ 300s, avg ]
SubMsgThroughputOut
消费流量
消息消费流量
Bytes/s
environmentId
subName
tenantId
topicName
[ 60s, sum ]
[ 300s, avg ]
[ 3600s, avg ]
[ 86400s, avg ]
PulsarSubscriptionTagFilterRejectedBytesRate
标签过滤消息流量
标签过滤消息流量
Bytes/s
environmentId
subName
tenantId
topicName
[ 60s, sum ]
[ 300s, avg ]
SubMsgBacklog
积压消息量
所选时间范围内,已经生产到 TDMQ,但并未被消费的消息数量。消息堆积不宜太多,如有明显增长趋势,请对消费者服务进行扩容以减少堆积量
Count
environmentId
subName
tenantId
topicName
[ 60s, sum ]
[ 300s, avg ]
SubBackLogNoDelayed
非延迟消息堆积数量
所选时间范围内,已经生产到 TDMQ,但并未被消费的非延迟消息数量
Count
tenantId
topicName
environmentId
subName
[ 60s, sum ]
[ 300s, avg ]
[ 3600s, avg ]
[ 86400s, avg ]
SubMsgDelayed
延迟消息消息量
所选时间范围内,使用了 TDMQ 延迟消息功能的消息数量,这种消息在生产后不会马上被消费,用户会指定一个延迟时间,过后才允许消费者消费
Count
environmentId
subName
tenantId
topicName
[ 60s, sum ]
[ 300s, avg ]
[ 3600s, avg ]
[ 86400s, avg ]
SubUnackedMsg
未确认消息数
在所选时间范围内,已发送给消费者消息但是没有接收到确认信息回传的消息数量。如果存在很多这种消息,请检查您的消费者服务是否正常,以及是否使用官方 SDK 进行消费
Count
environmentId
subName
tenantId
topicName
[ 60s, sum ]
[ 300s, avg ]
[ 3600s, avg ]
[ 86400s, avg ]
SubMsgUnackLimit
未确认消息数已使用配额百分比
未确认消息是指已推送到客户端后尚未收到确认的消息,配额消耗完后会停止推送,等待客户端处理和确认
%
environmentId
subName
tenantId
topicName
[ 60s, max ]
[ 300s, max ]
[ 3600s, max ]
[ 86400s, max ]
SubNonContiguousDeletedMessagesRanges
消息空洞数
非连续确认消息范围的数量,取订阅下各分区的最大值
Count
environmentId
subName
tenantId
topicName
[ 60s, max ]
[ 300s, avg ]
[ 3600s, avg ]
[ 86400s, avg ]
SubNonContiguousDeletedMessagesRangesToPersistPercent
已用消息空洞数占比
消息空洞数/最大消息空洞数*%
%
subName
tenantId
topicName
environmentId
[ 60s, expr ]
[ 300s, max ]
[ 3600s, max ]
[ 86400s, max ]
SubIsolationConsumerCount
异常消费者数量
当前订阅下异常消费者的数量
Count
environmentId
subName
tenantId
topicName
[ 60s, max ]
[ 300s, max ]
[ 3600s, max ]
[ 86400s, max ]
SubMsgExpired
消息过期数量
消息过期删除数量
Count
subName
tenantId
topicName
environmentId
[ 60s, sum ]
[ 300s, avg ]
[ 3600s, avg ]
[ 86400s, avg ]
SubMsgRateRedeliver
消息重传速率
在所选时间范围中,本 Topic 下某一秒内所有的重传消息的数量
Count/s
environmentId
subName
tenantId
topicName
[ 60s, sum ]
[ 300s, avg ]
SubscriptionsCount
订阅者数量
订阅者数量
Count
environmentId
tenantId
topicName
[ 60s, last ]
[ 300s, avg ]
SubConsumerCount
消费者数量
在所选时间范围内有效连接上本 Topic 的消费者数量。
Count
subName
tenantId
topicName
environmentId
[ 60s, last ]
[ 300s, avg ]
[ 3600s, avg ]
[ 86400s, avg ]
TenantInEntryCount
生产消息 entry 数量
生产消息 entry 数量
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantInEntrySizeLe100Kb
生产消息大小16KB_100KB的 entry 数量
生产消息大小16KB_100KB的 entry 数量
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantInEntrySizeLe128
生产消息小于等于128B的 entry 数量
生产消息小于等于128B的 entry 数量
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantInEntrySizeLe16Kb
生产消息大小4KB_16KB的 entry 数量
生产消息大小1KB_2KB的 entry 数量
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantInEntrySizeLe1Kb
生产消息大小512B_1KB的 entry 数量
生产消息大小512B_1KB的 entry 数量
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantInEntrySizeLe1Mb
生产消息大小100KB_1MB的 entry 数量
生产消息大小100KB_1MB的 entry 数量
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantInEntrySizeLe2Kb
生产消息大小1KB_2KB的 entry 数量
生产消息大小1KB_2KB的 entry 数量
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantInEntrySizeLe4Kb
生产消息大小2KB_4KB的 entry 数量
生产消息大小2KB_4KB的 entry 数量
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantInEntrySizeLe512
生产消息大小128B_512B的 entry 数量
生产消息大小128B_512B的 entry 数量
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantInEntrySizeLeOverflow
生产消息大小大于1MB的 entry 数量
生产消息大小1KB_2KB的 entry 数量
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantInEntrySizeSum
生产消息 entry 总大小
生产消息 entry 总大小
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantInMessagesTotal
虚拟集群入消息总数
虚拟集群入消息总数
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantMsgAverageSize
租户级别消息平均大小
租户级别消息平均大小
Bytes
tenant
[ 60s, expr ]
[ 300s, avg ]
TenantOutEntrySizeCount
消费消息 entry 数量
消费消息 entry 数量
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantOutEntrySizeLe100Kb
消费消息大小16KB_100KB的 entry 数量
消费消息大小16KB_100KB的 entry 数量
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantOutEntrySizeLe128
消费消息大小小于128B的 entry 数量
消费消息小于等于128B的 entry 数量
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantOutEntrySizeLe16Kb
消费消息大小4KB_16KB的 entry 数量
消费消息大小4KB_16KB的 entry 数量
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantOutEntrySizeLe1Kb
消费消息大小512B_1KB的 entry 数量
消费消息大小512B_1KB的 entry 数量
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantOutEntrySizeLe1Mb
消费消息大小100KB_1MB的 entry 数量
消费消息大小100KB_1MB的 entry 数量
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantOutEntrySizeLe2Kb
消费消息大小1KB_2KB的 entry 数量
消费消息大小1KB_2KB的 entry 数量
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantOutEntrySizeLe4Kb
消费消息大小2KB_4KB的 entry 数量
消费消息大小2KB_4KB的 entry 数量
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantOutEntrySizeLe512
消费消息大小128B_512B的 entry 数量
消费消息大小128B_512B的 entry 数量
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantOutEntrySizeLeOverflow
消费消息大于1MB的 entry 数量
消费消息大于1MB的 entry 数量
Count
tenant
[ 60s, sum ]
[ 300s, avg ]
TenantOutEntrySizeSum
消费消息 entry 总大小
消费消息 entry 总大小
Count
tenant
[ 60s, sum ]
[ 300s, avg ]

各维度对应参数总览

参数名称
维度名称
维度解释
维度解释
Instances.N.Dimensions.0.Name
environmentId
environmentId 的维度名称
输入 String 类型维度名称:environmentId
Instances.N.Dimensions.0.Value
environmentId
具体命名空间
输入具体命名空间,例如:default
可从 DescribeEnvironments 接口中获取,字段名为“EnvironmentId”
Instances.N.Dimensions.0.Name
tenantId
集群 ID 的维度名称
输入 String 类型维度名称:tenantId
Instances.N.Dimensions.0.Value
tenantId
具体集群 ID
输入具体集群 ID,例如:pulsar-xxxxxxxxxx
或从 DescribeClusterDetail 接口中获取,字段名为“ClusterId”
Instances.N.Dimensions.0.Name
topicName
主题名称的维度名称
输入 String 类型维度名称:topicName
Instances.N.Dimensions.0.Value
topicName
具体主题名称
具体主题名称,例如:testTopic
Instances.N.Dimensions.0.Name
tenant
集群 ID 的维度名称
输入 String 类型维度名称:tenant
Instances.N.Dimensions.0.Value
tenant
具体集群 ID
输入具体集群 ID,例如:pulsar-xxxxxxxxxx
可从 DescribeClusterDetail 中获取,字段“ClusterId”
Instances.N.Dimensions.0.Name
subName
订阅名称的维度名称
输入 String 类型维度名称:subName
Instances.N.Dimensions.0.Value
subName
订阅名称
输入 String 类型的订阅名称,可以在 消息队列 TDMQ Pulsar 版控制台 单击某个Topic 的详情页 > 消费者进行复制

入参说明

查询消息队列监控数据,入参取值如下:
指标类型一(订阅与主题维度指标):
&Namespace = QCE/TDMQ
&Instances.N.Dimensions.0.Name = environmentId
&Instances.N.Dimensions.0.Value = 具体命名空间
&Instances.N.Dimensions.1.Name = tenantId
&Instances.N.Dimensions.1.Value = 具体集群 ID
&Instances.N.Dimensions.2.Name = topicName
&Instances.N.Dimensions.2.Value = 具体主题名称
&Instances.N.Dimensions.3.Name = subName
&Instances.N.Dimensions.3.Value = 具体订阅名称
指标类型二(租户维度指标):
&Namespace = QCE/TDMQ
&Instances.N.Dimensions.0.Name = tenant
&Instances.N.Dimensions.0.Value = 具体集群 ID