class Processor implements Runnable {

    public void queue(ConsumerRecord<K, V> record) throws InterruptedException {
        queue.put(record);
    }

      Processor(TopicPartition topicPartition, ConsumerRecordRelay<K, V> relay, java.util.function.Consumer<V> action,
            int queueSize);

}