Github
来源:Apache
浏览 500
扫码
分享
2022-04-18 21:55:33
Pulsar stats
分区 topic
统计信息 | 说明 |
---|
msgRateIn | 所有本地 producer 和复制 producer 的发布频率总和,以消息数/秒为单位。 |
msgThroughputIn | 与 msgRateIn 相同,但以字节/秒作为单位。 |
msgRateOut | 所有本地 consumer 和复制 consumer 的调度频率总和,以消息数/秒为单位。 |
msgThroughputOut | 与 msgRateOut 相同,但以字节/秒为单位。 |
averageMsgSize | Producer 在最后一段时间间隔内发布消息的平均大小,以字节为单位。 |
storageSize | Topic 中所有 ledger 存储大小的总和。 |
publishers | The list of all local publishers into the topic. Publishers can be anywhere from zero to thousands. |
producerId | Topic 上 producer 的内部标识符。 |
producerName | 由客户端库生成的 producer 的内部标识符,。 |
address | Producer 连接的 IP 地址和 source 端口。 |
connectedSince | Producer 创建或最后一次重新连接的时间戳。 |
subscriptions | Topic 所有本地订阅的列表。 |
my-subscription | 订阅名称(由客户端定义)。 |
msgBacklog | 订阅中积压消息的数量。 |
type | 订阅的类型。 |
msgRateExpired | 由于 TTL,订阅中丢弃消息,而非调度消息的频率。 |
consumers | 订阅已连接 consumer 的列表。 |
consumerName | 由客户端库生成的 consumer 的内部标识符。 |
availablePermits | Consumer 在客户端监听队列中所能容纳的最大消息数。 值为 0 意味着客户端库队列已满,receive() 不再被调用。 非零值意味着 consumer 可以接收消息。 |
replication | Topic 上 cross-colo 复制的统计信息。 |
replicationBacklog | 待复制到远程集群的消息数。 |
connected | 出站复制器是否已连接。 |
replicationDelayInSeconds | 已连接状态下,若通过此连接发送最旧的消息,则此消息已经等待的时间。 |
inboundConnection | 远程集群到此集群 producer 连接中,broker 的 IP 和端口。 |
inboundConnectedSince | The TCP connection being used to publish messages to the remote cluster. If no local publishers are connected, this connection is automatically closed after a minute. |
Topic
统计信息 | 说明 |
---|
entriesAddedCounter | 此 broker 加载此 topic 后发布的消息。 |
numberOfEntries | 正在追踪的消息总数。 |
totalSize | 所有消息存储大小的总和(以字节为单位)。 |
currentLedgerEntries | 当前开放写入的 ledger 中,写入消息的总数。 |
currentLedgerSize | 当前开放写入的 ledger 中,写入消息的大小(以字节为单位)。 |
lastLedgerCreatedTimestamp | 上一个 ledger 的创建时间。 |
lastLedgerCreationFailureTimestamp | 上一次 ledger 创建失败的时间。 |
waitingCursorsCount | 跟上消息发布的进度,正在等待新消息发布的游标数量。 |
pendingAddEntriesCount | 正在等待完成(异步)写入请求的消息数。 |
lastConfirmedEntry | The ledgerid:entryid of the last message successfully written. If the entryid is -1, then the ledger is opened or is being currently opened but has no entries written yet. |
state | The state of the cursor ledger. Open means you have a cursor ledger for saving updates of the markDeletePosition. |
ledgers | Topic 上用于保存消息的所有 ledger 的有序列表。 |
cursors | The list of all cursors on this topic. Every subscription you saw in the topic stats has one. |
markDeletePosition | The ack position:订阅者确认的最后一条消息。 |
readPosition | 订阅者最后读取消息的位置。 |
waitingReadOp | 若订阅已读取发布到 topic 的最新消息,并且正在等待新消息的发布,则值为 true。 |
pendingReadOps | BookKeeper 中正在处理的读取请求数量计数。 |
messagesConsumedCounter | Broker 加载 topic 后,此游标已确认的消息总数。 |
cursorLedger | 用于持久存储当前 markDeletePosition 的 ledger。 |
cursorLedgerLastEntry | 最后一个用于持久存储当前 markDeletePosition 的 entryid。 |
individuallyDeletedMessages | 如果消息被乱序确认,则显示在 markDeletePosition 和 read-position 之间已确认消息的范围。 |
lastLedgerSwitchTimestamp | 游标 ledger 上一次轮询的时间。 |