Package org.apache.pulsar.client.api
Interface PartitionedTopicProducerStats
- All Superinterfaces:
ProducerStats
,Serializable
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
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()- Specified by:
getPartitionStats
in interfaceProducerStats
- Returns:
- stats for each partition if topic is partitioned topic
-