diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerStats.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerStats.java index e488aa81151ce..71234f3809c89 100644 --- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerStats.java +++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerStats.java @@ -49,7 +49,7 @@ public interface ConsumerStats extends Serializable { long getNumBytesReceived(); /** - * @return Rate of bytes per second received in the last interval + * @return Rate of messages per second received in the last interval */ double getRateMsgsReceived();