class SnowdropKafkaConsumer implements KafkaConsumer<K, V> {

    @Override
    public Mono<Long> endOffset(Partition partition) {
        Objects.requireNonNull(partition, "Partition cannot be null");

        return delegate.endOffsets(toVertxTopicPartition(partition)).convert().with(UniReactorConverters.toMono());
    }

      SnowdropKafkaConsumer(io.vertx.mutiny.kafka.client.consumer.KafkaConsumer<K, V> delegate);

}