@Test
public void testProcessZeroMetrics() {

    ConsumerRecords<String, MappedMetricData> metricRecords = AnomaliesProcessorTest.buildMetricRecords(0,
            AnomalyLevel.STRONG);
    when(kafkaConsumer.poll(anyLong())).thenReturn(metricRecords);
    assertTrue(anomalyConsumer.process(kafkaConsumer, true));
}