@Test
public void relayWithException() throws Exception {

    when(consumer.poll(anyLong())).thenThrow(RuntimeException.class);
    ConsumerRecordRelay<Integer, String> relay = new ConsumerRecordRelay<>(consumer, blockingQueueConsumer);
    new Thread(relay).start();
    verify(blockingQueueConsumer, never()).relay(record);
    verify(consumer, timeout(1000).only()).poll(anyLong());
    relay.stop();
}