@Test
public void testProcessMetrics() {

    ConsumerRecords<String, MappedMetricData> metricDataConsumerRecords = buildMetricRecords(2, AnomalyLevel.STRONG);
    List<AnomalyModel> anomalyModels = anomaliesProcessor.processMetrics(metricDataConsumerRecords, executorService);
    assertNotNull(anomalyModels);
    assertTrue(anomalyModels.size() == 2);
}