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

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