Pulsar stats

    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.