@Test
void statName() {

    var metrics = new ConsumerMetrics("log");
    assertEquals("kafka_consumer_log_lag_max", metrics.statName("lag_max"));
    metrics = new ConsumerMetrics(null);
    assertEquals("kafka_consumer_lag_max", metrics.statName("lag_max"));
}