Pulsar stats

分区 topic

统计信息说明
msgRateIn所有本地 producer 和复制 producer 的发布频率总和,以消息数/秒为单位。
msgThroughputIn与 msgRateIn 相同,但以字节/秒作为单位。
msgRateOut所有本地 consumer 和复制 consumer 的调度频率总和,以消息数/秒为单位。
msgThroughputOut与 msgRateOut 相同,但以字节/秒为单位。
averageMsgSizeProducer 在最后一段时间间隔内发布消息的平均大小,以字节为单位。
storageSizeTopic 中所有 ledger 存储大小的总和。
publishersThe list of all local publishers into the topic. Publishers can be anywhere from zero to thousands.
producerIdTopic 上 producer 的内部标识符。
producerName由客户端库生成的 producer 的内部标识符,。
addressProducer 连接的 IP 地址和 source 端口。
connectedSinceProducer 创建或最后一次重新连接的时间戳。
subscriptionsTopic 所有本地订阅的列表。
my-subscription订阅名称(由客户端定义)。
msgBacklog订阅中积压消息的数量。
type订阅的类型。
msgRateExpired由于 TTL,订阅中丢弃消息,而非调度消息的频率。
consumers订阅已连接 consumer 的列表。
consumerName由客户端库生成的 consumer 的内部标识符。
availablePermitsConsumer 在客户端监听队列中所能容纳的最大消息数。 值为 0 意味着客户端库队列已满,receive() 不再被调用。 非零值意味着 consumer 可以接收消息。
replicationTopic 上 cross-colo 复制的统计信息。
replicationBacklog待复制到远程集群的消息数。
connected出站复制器是否已连接。
replicationDelayInSeconds已连接状态下,若通过此连接发送最旧的消息,则此消息已经等待的时间。
inboundConnection远程集群到此集群 producer 连接中,broker 的 IP 和端口。
inboundConnectedSinceThe 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正在等待完成(异步)写入请求的消息数。
lastConfirmedEntryThe 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.
stateThe state of the cursor ledger. Open means you have a cursor ledger for saving updates of the markDeletePosition.
ledgersTopic 上用于保存消息的所有 ledger 的有序列表。
cursorsThe list of all cursors on this topic. Every subscription you saw in the topic stats has one.
markDeletePositionThe ack position:订阅者确认的最后一条消息。
readPosition订阅者最后读取消息的位置。
waitingReadOp若订阅已读取发布到 topic 的最新消息,并且正在等待新消息的发布,则值为 true。
pendingReadOpsBookKeeper 中正在处理的读取请求数量计数。
messagesConsumedCounterBroker 加载 topic 后,此游标已确认的消息总数。
cursorLedger用于持久存储当前 markDeletePosition 的 ledger。
cursorLedgerLastEntry最后一个用于持久存储当前 markDeletePosition 的 entryid。
individuallyDeletedMessages如果消息被乱序确认,则显示在 markDeletePosition 和 read-position 之间已确认消息的范围。
lastLedgerSwitchTimestamp游标 ledger 上一次轮询的时间。