private AtomicBoolean closed;
private Consumer<String, byte[]> consumer;
private String topic;
Queue<ConsumerRecord<String, byte[]>> queue;
private Vertx vertx;
<BUG>private String ebQueue;
public KafkaConsumerRunner(Properties props, String topic, Queue<ConsumerRecord<String, byte[]>> queue, Vertx vertx, String ebQueue) {
</BUG>
this.closed = new AtomicBoolean(false);
this.consumer = new KafkaConsumer<>(props);

private AtomicBoolean closed;
private Consumer<String, byte[]> consumer;
private String topic;
Queue<ConsumerRecord<String, byte[]>> queue;
private Vertx vertx;
private String ebQueue;
private ProtonQoS qos;
private CyclicBarrier barrier;
public KafkaConsumerRunner(Properties props, String topic, Queue<ConsumerRecord<String, byte[]>> queue, Vertx vertx, String ebQueue, ProtonQoS qos, CyclicBarrier barrier) {
this.closed = new AtomicBoolean(false);
this.consumer = new KafkaConsumer<>(props);
