public void recordFetchDelay(long fetchDelay) {
        this.fetchDelay = fetchDelay;
    }
@Test
    public void testFetchEventTimeLagTracking() {
        sourceMetrics.recordFetchDelay(5L);
        assertGauge(metricListener, CURRENT_FETCH_EVENT_TIME_LAG, 5L);
    }