Pulsar stats

Partitioned topics

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.

Topics

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.