@Test
public void handleEventExceptionWithEventNull() throws IOException, InterruptedException {

    consumerExceptionHandler.handleEventException(new Throwable(), 1, null);
    TestUtil.waitForAsyncLog();
    File log = customFileLog("sync.log");
    List<String> logs = FileUtils.readLines(log);
    assertTrue(logs.toString(), logs.get(0).contains("[ERROR]"));
}