Skip to content

Commit 7384c3e

Browse files
committed
docs: update comments
Signed-off-by: Ning Yu <[email protected]>
1 parent 382f9a7 commit 7384c3e

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

core/src/main/scala/kafka/server/streamaspect/BrokerQuotaManager.scala

+2-1
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,8 @@ class BrokerQuotaManager(private val config: BrokerQuotaManagerConfig,
5252

5353
/**
5454
* Get the value of the metric for the given quota type at the given time.
55-
* It return empty if the metric is not found, which is possible if the quota is disabled.
55+
* It return empty if the metric is not found, which is possible if the quota is disabled or no request has been
56+
* processed yet.
5657
*/
5758
def getQuotaMetricValue(quotaType: QuotaType, timeMs: Long): Optional[java.lang.Double] = {
5859
Optional.ofNullable(metrics.metric(clientQuotaMetricName(quotaType, metricsTags)))

0 commit comments

Comments
 (0)