void recordBytesFetched(int bytes) {
        bytesFetched.record(bytes);
    }
@Test
    public void testBytesFetched() {
        shareFetchMetricsManager.recordBytesFetched(2);
        time.sleep(metrics.config().timeWindowMs() + 1);
        shareFetchMetricsManager.recordBytesFetched(10);

        assertEquals(10, (double) getMetric(shareFetchMetricsRegistry.fetchSizeMax).metricValue());
        assertEquals(6, (double) getMetric(shareFetchMetricsRegistry.fetchSizeAvg).metricValue(), EPSILON);
    }