| id | title | sidebar_label |
|---|---|---|
administration-stats |
Pulsar stats |
Pulsar statistics |
| Stat | Description |
|---|---|
| msgRateIn | The sum of publish rates of all local and replication publishers in messages per second. |
| msgThroughputIn | Same as msgRateIn but in bytes per second instead of messages per second. |
| msgRateOut | The sum of dispatch rates of all local and replication consumers in messages per second. |
| msgThroughputOut | Same as msgRateOut but in bytes per second instead of messages per second. |
| averageMsgSize | Average message size, in bytes, from this publisher within the last interval. |
| storageSize | The sum of storage size of the ledgers for this topic. |
| publishers | The list of all local publishers into the topic. Publishers can be anywhere from zero to thousands. |
| producerId | Internal identifier for this producer on this topic. |
| producerName | Internal identifier for this producer, generated by the client library. |
| address | IP address and source port for the connection of this producer. |
| connectedSince | Timestamp this producer is created or last reconnected. |
| subscriptions | The list of all local subscriptions to the topic. |
| my-subscription | The name of this subscription (client defined). |
| msgBacklog | The count of messages in backlog for this subscription. |
| type | This subscription type. |
| msgRateExpired | The rate at which messages are discarded instead of dispatched from this subscription due to TTL. |
| consumers | The list of connected consumers for this subscription. |
| consumerName | Internal identifier for this consumer, generated by the client library. |
| availablePermits | The number of messages this consumer has space for in the listen queue of client library. A value of 0 means the queue of client library is full and receive() is not being called. A nonzero value means this consumer is ready to be dispatched messages. |
| replication | This section gives the stats for cross-colo replication of this topic. |
| replicationBacklog | The outbound replication backlog in messages. |
| connected | Whether the outbound replicator is connected. |
| replicationDelayInSeconds | How long the oldest message has been waiting to be sent through the connection, if connected is true. |
| inboundConnection | The IP and port of the broker in the publisher connection of remote cluster to this broker. |
| 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. |
| Stat | Description |
|---|---|
| entriesAddedCounter | Messages published since this broker loads this topic. |
| numberOfEntries | Total number of messages being tracked. |
| totalSize | Total storage size in bytes of all messages. |
| currentLedgerEntries | Count of messages written to the ledger currently open for writing. |
| currentLedgerSize | Size in bytes of messages written to ledger currently open for writing. |
| lastLedgerCreatedTimestamp | Time when last ledger is created. |
| lastLedgerCreationFailureTimestamp | Time when last ledger is failed. |
| waitingCursorsCount | How many cursors are caught up and waiting for a new message to be published. |
| pendingAddEntriesCount | How many messages have (asynchronous) write requests you are waiting on completion. |
| 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 | The ordered list of all ledgers for this topic holding its messages. |
| cursors | The list of all cursors on this topic. Every subscription you saw in the topic stats has one. |
| markDeletePosition | The ack position: the last message the subscriber acknowledges receiving. |
| readPosition | The latest position of subscriber for reading message. |
| waitingReadOp | This is true when the subscription reads the latest message that is published to the topic and waits on new messages to be published. |
| pendingReadOps | The counter for how many outstanding read requests to the BookKeepers you have in progress. |
| messagesConsumedCounter | Number of messages this cursor acks since this broker loads this topic. |
| cursorLedger | The ledger used to persistently store the current markDeletePosition. |
| cursorLedgerLastEntry | The last entryid used to persistently store the current markDeletePosition. |
| individuallyDeletedMessages | If Acks are done out of order, shows the ranges of messages Acked between the markDeletePosition and the read-position. |
| lastLedgerSwitchTimestamp | The last time the cursor ledger is rolled over. |