    @Test
    public void testProcessZeroMetrics() {

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

    }