Package org.apache.pulsar.client.api

Interface MultiTopicConsumerStats

All Superinterfaces:

ConsumerStats, Serializable

@Public
@Stable
public interface MultiTopicConsumerStats
extends ConsumerStats

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

Modifier and Type	Method	Description
Map<String,ConsumerStats>	getPartitionStats()

Methods inherited from interface org.apache.pulsar.client.api.ConsumerStats

getMsgNumInReceiverQueue, getMsgNumInSubReceiverQueue, getNumAcksFailed, getNumAcksSent, getNumBatchReceiveFailed, getNumBytesReceived, getNumMsgsReceived, getNumReceiveFailed, getRateBytesReceived, getRateMsgsReceived, getTotaBatchReceivedFailed, getTotalAcksFailed, getTotalAcksSent, getTotalBytesReceived, getTotalMsgsReceived, getTotalReceivedFailed

Method Details

getPartitionStats

Map<String,ConsumerStats> getPartitionStats()

Specified by:

getPartitionStats in interface ConsumerStats

Returns:

stats for each partition if topic is partitioned topic