Pulsar stats

Partitioned topics

StatDescription
msgRateInThe sum of publish rates of all local and replication publishers in messages per second.
msgThroughputInSame as msgRateIn but in bytes per second instead of messages per second.
msgRateOutThe sum of dispatch rates of all local and replication consumers in messages per second.
msgThroughputOutSame as msgRateOut but in bytes per second instead of messages per second.
averageMsgSizeAverage message size, in bytes, from this publisher within the last interval.
storageSizeThe sum of storage size of the ledgers for this topic.
publishersThe list of all local publishers into the topic. Publishers can be anywhere from zero to thousands.
producerIdInternal identifier for this producer on this topic.
producerNameInternal identifier for this producer, generated by the client library.
addressIP address and source port for the connection of this producer.
connectedSinceTimestamp this producer is created or last reconnected.
subscriptionsThe list of all local subscriptions to the topic.
my-subscriptionThe name of this subscription (client defined).
msgBacklogThe count of messages in backlog for this subscription.
typeThis subscription type.
msgRateExpiredThe rate at which messages are discarded instead of dispatched from this subscription due to TTL.
consumersThe list of connected consumers for this subscription.
consumerNameInternal identifier for this consumer, generated by the client library.
availablePermitsThe 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.
replicationThis section gives the stats for cross-colo replication of this topic.
replicationBacklogThe outbound replication backlog in messages.
connectedWhether the outbound replicator is connected.
replicationDelayInSecondsHow long the oldest message has been waiting to be sent through the connection, if connected is true.
inboundConnectionThe IP and port of the broker in the publisher connection of remote cluster to this broker.
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.

Topics

StatDescription
entriesAddedCounterMessages published since this broker loads this topic.
numberOfEntriesTotal number of messages being tracked.
totalSizeTotal storage size in bytes of all messages.
currentLedgerEntriesCount of messages written to the ledger currently open for writing.
currentLedgerSizeSize in bytes of messages written to ledger currently open for writing.
lastLedgerCreatedTimestampTime when last ledger is created.
lastLedgerCreationFailureTimestampTime when last ledger is failed.
waitingCursorsCountHow many cursors are caught up and waiting for a new message to be published.
pendingAddEntriesCountHow many messages have (asynchronous) write requests you are waiting on completion.
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.
ledgersThe ordered list of all ledgers for this topic holding its messages.
cursorsThe list of all cursors on this topic. Every subscription you saw in the topic stats has one.
markDeletePositionThe ack position: the last message the subscriber acknowledges receiving.
readPositionThe latest position of subscriber for reading message.
waitingReadOpThis is true when the subscription reads the latest message that is published to the topic and waits on new messages to be published.
pendingReadOpsThe counter for how many outstanding read requests to the BookKeepers you have in progress.
messagesConsumedCounterNumber of messages this cursor acks since this broker loads this topic.
cursorLedgerThe ledger used to persistently store the current markDeletePosition.
cursorLedgerLastEntryThe last entryid used to persistently store the current markDeletePosition.
individuallyDeletedMessagesIf Acks are done out of order, shows the ranges of messages Acked between the markDeletePosition and the read-position.
lastLedgerSwitchTimestampThe last time the cursor ledger is rolled over.