class CheramiConsumerImpl implements CheramiConsumer, Reconfigurable {

    @Override
    public synchronized void close() {
        if (isOpen.getAndSet(false)) {
            connectionManager.close();
            deliveryRunnable.stop();
            cleanup();
        }
        logger.info("Consumer closed");
    }

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

}