You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Shivsundar R (Jira)" <ji...@apache.org> on 2025/02/19 16:31:00 UTC
[jira] [Commented] (KAFKA-15636) Investigate FetcherTest's/FetchRequestManager's testFetchResponseMetrics
[ https://issues.apache.org/jira/browse/KAFKA-15636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928493#comment-17928493 ]
Shivsundar R commented on KAFKA-15636:
--------------------------------------
Hi [~kirktrue] , I was looking into this. Yes expectedBytes is calculated as total instead of avg.
{code:java}
assertEquals(expectedBytes, (Double) fetchSizeAverage.metricValue(), EPSILON);{code}
In {color:#FF0000}*{color:#172b4d}testFetchResponseMetrics{color}* {color}{color:#172b4d}we are building a single fetch request to 2 topics. So h{color}ere *fetchSizeAvg* would be same as *bytesConsumedTotal.* Hence the test passes.{color:#172b4d}
{color}
{code:java}
/* Client level */
String groupName = metricGrpPrefix + "-fetch-manager-metrics";
this.fetchSizeAvg = new MetricNameTemplate("fetch-size-avg", groupName,
"The average number of bytes fetched per request", tags);
this.fetchSizeMax = new MetricNameTemplate("fetch-size-max", groupName,
"The maximum number of bytes fetched per request", tags);
this.bytesConsumedRate = new MetricNameTemplate("bytes-consumed-rate", groupName,
"The average number of bytes consumed per second", tags);
this.bytesConsumedTotal = new MetricNameTemplate("bytes-consumed-total", groupName,
"The total number of bytes consumed", tags); {code}
{color:#172b4d}Should I add another fetch request in the test, then testing for fetchSizeAvg would make sense, else we can change this metric check to *bytes-consumed-total* instead of *fetch-size-avg,* then it would make more sense for the existing test.{color}
> Investigate FetcherTest's/FetchRequestManager's testFetchResponseMetrics
> ------------------------------------------------------------------------
>
> Key: KAFKA-15636
> URL: https://issues.apache.org/jira/browse/KAFKA-15636
> Project: Kafka
> Issue Type: Test
> Components: clients, consumer, unit tests
> Reporter: Kirk True
> Assignee: Shivsundar R
> Priority: Minor
> Labels: consumer-threading-refactor, fetcher, unit-tests
>
> {{expectedBytes}} is calculated as total, instead of avg. Is this correct?
--
This message was sent by Atlassian Jira
(v8.20.10#820010)