private Vertx vertx;
private Queue<ConsumerRecord<String, byte[]>> queue;
private String ebQueue;
private MessageConsumer<String> ebConsumer;
private MessageConverter<String, byte[]> converter;
<BUG>private int deliveryTag;
public SinkBridgeEndpoint(Vertx vertx) {</BUG>
this.vertx = vertx;
this.queue = new ConcurrentLinkedQueue<ConsumerRecord<String, byte[]>>();
this.converter = new DefaultMessageConverter();

private Vertx vertx;
private Queue<ConsumerRecord<String, byte[]>> queue;
private String ebQueue;
private MessageConsumer<String> ebConsumer;
private MessageConverter<String, byte[]> converter;
private int deliveryTag;
private CyclicBarrier barrier;
public SinkBridgeEndpoint(Vertx vertx) {
this.vertx = vertx;
this.queue = new ConcurrentLinkedQueue<ConsumerRecord<String, byte[]>>();
this.converter = new DefaultMessageConverter();
