@Test
public void defaultBatchListenerDoesntThrow() {

    // given
    BulkProcessorObjectFactory factory = createTestObjectFactoryBuilder().build();
    Function<BulkRequest, Boolean> batchListener = factory.createBatchListener(failedPayload -> {
        throw new ConfigurationException("test exception");
    });
    // when
    batchListener.apply(null);
}