Package org.apache.pulsar.client.api

Interface PartitionedTopicProducerStats

All Superinterfaces:

ProducerStats, Serializable

@Public
@Stable
public interface PartitionedTopicProducerStats
extends ProducerStats

Partitioned topic Producer 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,ProducerStats>	getPartitionStats()

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

getNumAcksReceived, getNumBytesSent, getNumMsgsSent, getNumSendFailed, getPendingQueueSize, getSendBytesRate, getSendLatencyMillis50pct, getSendLatencyMillis75pct, getSendLatencyMillis95pct, getSendLatencyMillis999pct, getSendLatencyMillis99pct, getSendLatencyMillisMax, getSendMsgsRate, getTotalAcksReceived, getTotalBytesSent, getTotalMsgsSent, getTotalSendFailed

Method Details

getPartitionStats

Map<String,ProducerStats> getPartitionStats()

Returns:

stats for each partition if topic is partitioned topic