this.closed = new AtomicBoolean(false);
this.consumer = new KafkaConsumer<>(props);
this.topic = topic;
this.queue = queue;
this.vertx = vertx;
<BUG>this.ebQueue = ebQueue;
}</BUG>
@Override
public void run() {
LOG.info("Apache Kafka consumer runner started ...");

this.closed = new AtomicBoolean(false);
this.consumer = new KafkaConsumer<>(props);
this.topic = topic;
this.queue = queue;
this.vertx = vertx;
this.ebQueue = ebQueue;
this.qos = qos;
this.barrier = barrier;
}
@Override
public void run() {
LOG.info("Apache Kafka consumer runner started ...");
