@Test
void collect() {

    var metrics = new ConsumerMetrics(null);
    var stats = new Stats();
    metrics.collect(stats);
    assertThat(stats.stats).containsKeys("kafka_consumer_records_max_lag",
            "kafka_consumer_records_consumed_rate",
            "kafka_consumer_bytes_consumed_rate",
            "kafka_consumer_fetch_rate");
}