class ConsumerNetworkClient implements Closeable {

    public void wakeup() {
        this.wakeup.set(true);
        this.client.wakeup();
    }

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

}