class CheramiConsumerImpl implements CheramiConsumer, Reconfigurable {

    @Override
    public CheramiFuture<CheramiDelivery> readAsync() throws IOException {
        if (!isOpen()) {
            throw new IOException("Consumer closed.");
        }
        CheramiFuture<CheramiDelivery> future = new CheramiFuture<>();
        futuresQueue.add(future);
        return future;
    }

    public  CheramiConsumerImpl(CheramiClient client, String dstPath, String consumerGroupName, ConsumerOptions options,
            MetricsReporter metricsReporter);

}