class ConsumerRecordRelay implements Runnable {

    void stop() {
        logger.info("Stopping Kafka message relay");
        stopped = true;
    }

    public  ConsumerRecordRelay(Consumer<K, V> consumer, BlockingQueueConsumer<K, V> blockingQueueConsumer);

}