Package org.apache.pulsar.client.api

Interface ProducerStats

All Superinterfaces:
Serializable
@Public @Stable public interface ProducerStats extends Serializable
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 Details

    • getNumMsgsSent

      long getNumMsgsSent()
      Returns:
      the number of messages published in the last interval

    • getNumBytesSent

      long getNumBytesSent()
      Returns:
      the number of bytes sent in the last interval

    • getNumSendFailed

      long getNumSendFailed()
      Returns:
      the number of failed send operations in the last interval

    • getNumAcksReceived

      long getNumAcksReceived()
      Returns:
      the number of send acknowledges received by broker in the last interval

    • getSendMsgsRate

      double getSendMsgsRate()
      Returns:
      the messages send rate in the last interval

    • getSendBytesRate

      double getSendBytesRate()
      Returns:
      the bytes send rate in the last interval

    • getSendLatencyMillis50pct

      double getSendLatencyMillis50pct()
      Returns:
      the 50th percentile of the send latency in milliseconds for the last interval

    • getSendLatencyMillis75pct

      double getSendLatencyMillis75pct()
      Returns:
      the 75th percentile of the send latency in milliseconds for the last interval

    • getSendLatencyMillis95pct

      double getSendLatencyMillis95pct()
      Returns:
      the 95th percentile of the send latency in milliseconds for the last interval

    • getSendLatencyMillis99pct

      double getSendLatencyMillis99pct()
      Returns:
      the 99th percentile of the send latency in milliseconds for the last interval

    • getSendLatencyMillis999pct

      double getSendLatencyMillis999pct()
      Returns:
      the 99.9th percentile of the send latency in milliseconds for the last interval

    • getSendLatencyMillisMax

      double getSendLatencyMillisMax()
      Returns:
      the max send latency in milliseconds for the last interval

    • getTotalMsgsSent

      long getTotalMsgsSent()
      Returns:
      the total number of messages published by this producer

    • getTotalBytesSent

      long getTotalBytesSent()
      Returns:
      the total number of bytes sent by this producer

    • getTotalSendFailed

      long getTotalSendFailed()
      Returns:
      the total number of failed send operations

    • getTotalAcksReceived

      long getTotalAcksReceived()
      Returns:
      the total number of send acknowledges received by broker

    • getPendingQueueSize

      int getPendingQueueSize()
      Returns:
      current pending send-message queue size of the producer