All stats below are reset to 0 upon broker restart or topic unloading, except the stats marked with asterisks * (the values of them keep unchanged).
|The sum of publish rates of all local and replication publishers in messages per second.
|Same as msgRateIn but in bytes per second instead of messages per second.
|The sum of dispatch rates of all local and replication consumers in messages per second.
|Same as msgRateOut but in bytes per second instead of messages per second.
|Average message size, in bytes, from this publisher within the last interval.
|The sum of the ledgers' storage size in BookKeeper for a topic (in bytes).
total storage size of a topic =
|The sum of the storage size in tiered storage for a topic (in bytes).
total storage size of a topic =
|The list of all local publishers into the topic. Publishers can be anywhere from zero to thousands.
|Internal identifier for this producer on this topic.
|Internal identifier for this producer, generated by the client library.
|IP address and source port for the connection of this producer.
|Timestamp this producer is created or last reconnected.
|The list of all local subscriptions to the topic.
|The name of this subscription (client defined).
|The count of messages in backlog for this subscription.
|This subscription type.
|The rate at which messages are discarded instead of dispatched from this subscription due to TTL.
|The list of connected consumers for this subscription.
|Internal identifier for this consumer, generated by the client library.
|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.
|This section gives the stats for cross-colo replication of this topic.
|The outbound replication backlog in messages.
|Whether the outbound replicator is connected.
|How long the oldest message has been waiting to be sent through the connection, if connected is true.
|The IP and port of the broker in the publisher connection of remote cluster to this broker.
|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.
|Messages published since this broker loads this topic.
|Total number of messages being tracked.
|Total storage size in bytes of all messages.
|Count of messages written to the ledger currently open for writing.
|Size in bytes of messages written to ledger currently open for writing.
|Time when last ledger is created.
|Time when last ledger is failed.
|How many cursors are caught up and waiting for a new message to be published.
|How many messages have (asynchronous) write requests you are waiting on completion.
|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.
|The state of the cursor ledger. Open means you have a cursor ledger for saving updates of the markDeletePosition.
|The ordered list of all ledgers for this topic holding its messages.
|The list of all cursors on this topic. Every subscription you saw in the topic stats has one.
|The ack position: the last message the subscriber acknowledges receiving.
|The latest position of subscriber for reading message.
|This is true when the subscription reads the latest message that is published to the topic and waits on new messages to be published.
|The counter for how many outstanding read requests to the BookKeepers you have in progress.
|Number of messages this cursor acks since this broker loads this topic.
|The ledger used to persistently store the current markDeletePosition.
|The last entryid used to persistently store the current markDeletePosition.
|If Acks are done out of order, shows the ranges of messages Acked between the markDeletePosition and the read-position.
|The last time the cursor ledger is rolled over.