@Test
public void testProcessWakeException() {

    when(kafkaConsumer.poll(anyLong())).thenThrow(WakeupException.class);
    assertFalse(anomalyConsumer.process(kafkaConsumer, true));
    verify(kafkaConsumer, times(1)).close();
}