@Override
    public void sleep(long ms) {
        timeMs.addAndGet(ms);
        highResTimeNs.addAndGet(TimeUnit.MILLISECONDS.toNanos(ms));
        tick();
    }
Listeners which are waiting for time changes.
clients/src/test/java/org/apache/kafka/common/utils/MockTime.java