class ConsumerNetworkClient implements Closeable {

    public void schedule(DelayedTask task, long at) {
        delayedTasks.add(task, at);
    }

    public  ConsumerNetworkClient(KafkaClient client,
        Metadata metadata,
        Time time,
        long retryBackoffMs,
        long requestTimeoutMs);

}