Package org.apache.pulsar.client.api
Interface MultiTopicConsumerStats
- All Superinterfaces:
ConsumerStats
,Serializable
Multi-topic Consumer statistics recorded by client.
All the stats are relative to the last recording period. The interval of the stats refreshes is configured with
ClientBuilder.statsInterval(long, java.util.concurrent.TimeUnit)
with a default of 1 minute.
-
Method Summary
Methods inherited from interface org.apache.pulsar.client.api.ConsumerStats
getDeadLetterProducerStats, getMsgNumInReceiverQueue, getMsgNumInSubReceiverQueue, getNumAcksFailed, getNumAcksSent, getNumBatchReceiveFailed, getNumBytesReceived, getNumMsgsReceived, getNumReceiveFailed, getRateBytesReceived, getRateMsgsReceived, getRetryLetterProducerStats, getTotaBatchReceivedFailed, getTotalAcksFailed, getTotalAcksSent, getTotalBytesReceived, getTotalMsgsReceived, getTotalReceivedFailed
-
Method Details
-
getPartitionStats
Map<String,ConsumerStats> getPartitionStats()- Specified by:
getPartitionStats
in interfaceConsumerStats
- Returns:
- stats for each partition if topic is partitioned topic
-