@Test(expected = IllegalStateException.class)
public void testRetryWithoutFail() throws Exception {

    ExponentialBackoffMsgRetryManager manager = new ExponentialBackoffMsgRetryManager(0, 0d, 0);
    manager.retryStarted(TEST_OFFSET);
}