@Override
    public ScheduledFuture<?> schedule(String name, Runnable task, long delayMs, long periodMs) {
        MockTask mockTask = new MockTask(name, task, time.milliseconds() + delayMs, periodMs, time);
        add(mockTask);
        tick();
        return mockTask;
    }
Not used, so not fully implemented
server-common/src/test/java/org/apache/kafka/server/util/MockScheduler.java