if (messageAnnotations != null) {
Object partition = messageAnnotations.getValue().get(Symbol.getSymbol("x-opt-bridge.partition"));
Object offset = messageAnnotations.getValue().get(Symbol.getSymbol("x-opt-bridge.offset"));
Object key = messageAnnotations.getValue().get(Symbol.getSymbol("x-opt-bridge.key"));
LOG.info("... on partition {} [{}], key = {}", partition, offset, key);
<BUG>}
}</BUG>
})
.open();
}

if (messageAnnotations != null) {
Object partition = messageAnnotations.getValue().get(Symbol.getSymbol("x-opt-bridge.partition"));
Object offset = messageAnnotations.getValue().get(Symbol.getSymbol("x-opt-bridge.offset"));
Object key = messageAnnotations.getValue().get(Symbol.getSymbol("x-opt-bridge.key"));
LOG.info("... on partition {} [{}], key = {}", partition, offset, key);
}
delivery.disposition(Accepted.getInstance(), true);
}
})
.open();
