    @Test(expected = TemporaryKafkaProcessingError.class)
    public void temporaryErrorShouldStoreEventAsUnprocessable() {

        final ProductEventProcessor processor = mockedProcessor(TEMPORARY_ERROR);
        productEventConsumer = new ProductEventConsumer(processor, unprocessableEventService);
        productEventConsumer.listen(CONSUMER_RECORD,ack);

        verify(ack, never()).acknowledge();
        verify(processor).processEvent(any());
        verify(unprocessableEventService).save(any());
    }